smengcl commented on code in PR #10721:
URL: https://github.com/apache/ozone/pull/10721#discussion_r3573445724
##########
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.
Review Comment:
Good point. Done!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
