This is an automated email from the ASF dual-hosted git repository.
adoroszlai 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 7f6ea8b1ac7 HDDS-16134. Fix flaky
testPipelineExclusionWithPipelineFailure (#11062)
7f6ea8b1ac7 is described below
commit 7f6ea8b1ac745f95d7a2db89d1d8e12586712170
Author: Y-C <[email protected]>
AuthorDate: Wed Aug 26 03:49:03 2026 +0800
HDDS-16134. Fix flaky testPipelineExclusionWithPipelineFailure (#11062)
---
.../apache/hadoop/ozone/client/rpc/TestFailureHandlingByClient.java | 3 ++-
.../ozone/client/rpc/TestFailureHandlingByClientFlushDelay.java | 4 ++--
2 files changed, 4 insertions(+), 3 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 4d971dfeb9e..13f2e458ee6 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
@@ -564,7 +564,8 @@ public void testPipelineExclusionWithPipelineFailure()
throws Exception {
assertThat(keyOutputStream.getExcludeList().getPipelineIds())
.contains(pipeline.getId());
assertThat(keyOutputStream.getExcludeList().getContainerIds()).isEmpty();
- assertThat(keyOutputStream.getExcludeList().getDatanodes()).isEmpty();
+ // Datanodes are not asserted: watchForCommit can time out against the
two shut down
+ // followers, which then get recorded as failed servers and added to the
exclude list.
// The close will just write to the buffer
}
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClientFlushDelay.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClientFlushDelay.java
index 8544313b1e2..bebba9c0c30 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClientFlushDelay.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestFailureHandlingByClientFlushDelay.java
@@ -185,8 +185,8 @@ public void testPipelineExclusionWithPipelineFailure()
throws Exception {
key.write(data.getBytes(UTF_8));
key.flush();
assertThat(keyOutputStream.getExcludeList().getContainerIds()).isEmpty();
- assertThat(keyOutputStream.getExcludeList().getDatanodes()).isEmpty();
- assertThat(keyOutputStream.getExcludeList().getDatanodes()).isEmpty();
+ // Datanodes are not asserted: watchForCommit can time out against the
two shut down
+ // followers, which then get recorded as failed servers and added to the
exclude list.
key.write(data.getBytes(UTF_8));
// The close will just write to the buffer
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
