This is an automated email from the ASF dual-hosted git repository.
jojochuang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new a8fcb09c023 HDDS-15823. Fix flaky
TestFailureHandlingByClient#testContainerExclusionWithClosedContainerException
(#10721)
a8fcb09c023 is described below
commit a8fcb09c0235cffabe9c0c344273d4a225367e42
Author: Siyao Meng <[email protected]>
AuthorDate: Tue Jul 14 15:24:42 2026 -0700
HDDS-15823. Fix flaky
TestFailureHandlingByClient#testContainerExclusionWithClosedContainerException
(#10721)
Co-authored-by: Claude Opus 4.8 (1M context) <[email protected]>
---
.../ozone/client/rpc/TestFailureHandlingByClient.java | 13 +++++++------
1 file changed, 7 insertions(+), 6 deletions(-)
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..5ccf9b98b18 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
@@ -394,13 +394,14 @@ public void
testContainerExclusionWithClosedContainerException()
assertThat(keyOutputStream.getExcludeList().getContainerIds())
.contains(ContainerID.valueOf(containerId));
- // Datanodes are not asserted here. Under the default ALL_COMMITTED watch
- // level a slow-but-healthy follower can be recorded in the exclude
list, so
- // an empty datanode set is not an invariant for this config (the watch
- // level is configurable via RatisClientConfig watchType, HDDS-2887).
- // Watch-level datanode exclusion is covered by
+ // The container-id assertion above is the actual property under test.
+ // Under the default ALL_COMMITTED watch level neither the datanode nor
the
+ // pipeline set is an invariant: a slow-but-healthy follower can be
recorded
+ // as a failed datanode, and a WATCH RaftRetryFailureException takes the
+ // else-branch in KeyOutputStream.handleException and excludes the
pipeline.
+ // The watch level is configurable via RatisClientConfig watchType
+ // (HDDS-2887); watch-level exclusion is covered by
// testDatanodeExclusionWithMajorityCommit.
- assertThat(keyOutputStream.getExcludeList().getPipelineIds()).isEmpty();
// The close will just write to the buffer
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
