Skip to content

Commit abbabf5

Browse files
HDDS-12624. Fixing testcase and adressed review comments
1 parent 3f1b2ac commit abbabf5

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/RatisPipelineProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ public synchronized Pipeline create(RatisReplicationConfig replicationConfig,
148148
throws IOException {
149149
if (exceedPipelineNumberLimit(replicationConfig)) {
150150
String limitInfo = (maxPipelinePerDatanode > 0)
151-
? String.format("per dataNode: %d", maxPipelinePerDatanode)
151+
? String.format("per datanode: %d", maxPipelinePerDatanode)
152152
: String.format(": %d", pipelineNumberLimit);
153153

154154
throw new SCMException(

hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/pipeline/TestRatisPipelineProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -384,7 +384,7 @@ public void testCreatePipelineThrowErrorWithDataNodeLimit(int limit, int pipelin
384384

385385
// Validate exception message.
386386
String expectedError = String.format(
387-
"Ratis pipeline number meets the limit per dataNode: %d replicationConfig: RATIS/THREE", limit);
387+
"Ratis pipeline number meets the limit per datanode: %d replicationConfig: RATIS/THREE", limit);
388388
assertEquals(expectedError, exception.getMessage());
389389
}
390390

hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/pipeline/TestRatisPipelineCreateAndDestroy.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ public void testPipelineCreationOnNodeRestart() throws Exception {
145145
pipelineManager.createPipeline(RatisReplicationConfig.getInstance(
146146
ReplicationFactor.THREE)),
147147
"pipeline creation should fail after shutting down pipeline");
148-
assertEquals(SCMException.ResultCodes.FAILED_TO_FIND_HEALTHY_NODES, ioe.getResult());
148+
assertEquals(SCMException.ResultCodes.FAILED_TO_FIND_SUITABLE_NODE, ioe.getResult());
149149

150150
// make sure pipelines is destroyed
151151
waitForPipelines(0);

0 commit comments

Comments
 (0)