diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClient.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClient.java index 01cb7e92544..045bddf9d7b 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClient.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClient.java @@ -400,7 +400,12 @@ public void testContainerExclusionWithClosedContainerException() // level is configurable via RatisClientConfig watchType, HDDS-2887). // Watch-level datanode exclusion is covered by // testDatanodeExclusionWithMajorityCommit. - assertThat(keyOutputStream.getExcludeList().getPipelineIds()).isEmpty(); + // Pipeline IDs are also not asserted here. Under ALL_COMMITTED a WATCH + // RaftRetryFailureException can fire (retryFailure=true) before the + // ClosedContainerException path runs; that takes the else-branch in + // KeyOutputStream.handleException and adds the pipeline to the exclude + // list, so an empty pipeline set is not an invariant for this config. + // The container-id assertion above is the actual property under test. // The close will just write to the buffer }