We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 91ba484 commit 19c7952Copy full SHA for 19c7952
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
@@ -671,9 +671,9 @@ private void checkStreamerFailures(boolean isNeedFlushAllPackets)
671
// for healthy streamers, wait till all of them have fetched the new block
672
// and flushed out all the enqueued packets.
673
flushAllInternals();
674
+ // recheck failed streamers again after the flush
675
+ newFailed = checkStreamers();
676
}
- // recheck failed streamers again after the flush
- newFailed = checkStreamers();
677
while (newFailed.size() > 0) {
678
failedStreamers.addAll(newFailed);
679
coordinator.clearFailureStates();
0 commit comments