Skip to content

Commit c8a17b0

Browse files
hfutatzhanghbslfan1989
authored andcommitted
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 4f4b846)
1 parent fbea6a6 commit c8a17b0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -671,9 +671,9 @@ private void checkStreamerFailures(boolean isNeedFlushAllPackets)
671671
// for healthy streamers, wait till all of them have fetched the new block
672672
// and flushed out all the enqueued packets.
673673
flushAllInternals();
674+
// recheck failed streamers again after the flush
675+
newFailed = checkStreamers();
674676
}
675-
// recheck failed streamers again after the flush
676-
newFailed = checkStreamers();
677677
while (newFailed.size() > 0) {
678678
failedStreamers.addAll(newFailed);
679679
coordinator.clearFailureStates();

0 commit comments

Comments
 (0)