This is an automated email from the ASF dual-hosted git repository.
slfan1989 pushed a commit to branch branch-3.4.0
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.4.0 by this push:
new c8a17b09c33d HDFS-17359. EC: recheck failed streamers should only
after flushing all packets. (#6503). Contributed by farmmamba.
c8a17b09c33d is described below
commit c8a17b09c33db0f518984977ab5cf643a7ef34b2
Author: hfutatzhanghb <[email protected]>
AuthorDate: Thu Feb 1 22:53:37 2024 +0800
HDFS-17359. EC: recheck failed streamers should only after flushing all
packets. (#6503). Contributed by farmmamba.
Signed-off-by: Takanobu Asanuma <[email protected]>
(cherry picked from commit 4f4b84698658c42efd5f7af0c6061546f6fb7ce8)
---
.../src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
index a58c7bbb204f..8320cc9a4086 100644
---
a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
+++
b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
@@ -671,9 +671,9 @@ public class DFSStripedOutputStream extends DFSOutputStream
// for healthy streamers, wait till all of them have fetched the new
block
// and flushed out all the enqueued packets.
flushAllInternals();
+ // recheck failed streamers again after the flush
+ newFailed = checkStreamers();
}
- // recheck failed streamers again after the flush
- newFailed = checkStreamers();
while (newFailed.size() > 0) {
failedStreamers.addAll(newFailed);
coordinator.clearFailureStates();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
