This is an automated email from the ASF dual-hosted git repository.
tasanuma pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4f4b84698658 HDFS-17359. EC: recheck failed streamers should only
after flushing all packets. (#6503). Contributed by farmmamba.
4f4b84698658 is described below
commit 4f4b84698658c42efd5f7af0c6061546f6fb7ce8
Author: hfutatzhanghb <hfutzhan...@163.com>
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 <tasan...@apache.org>
---
.../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: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
