Skip to content

Commit ac4c0ab

Browse files
author
Tom McCormick
committed
Fix for test
1 parent 69f6e0e commit ac4c0ab

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1357,7 +1357,7 @@ private void hedgedFetchBlockByteRange(LocatedBlock block, long start,
13571357
// have concurrent requests to the same node.
13581358
// Once all futures are cleared, we can clear the ignoredNodes and retry.
13591359
if (refetch && futures.isEmpty()) {
1360-
refetchLocations(block, ignored);
1360+
block = refetchLocations(block, ignored);
13611361
}
13621362
// We got here if exception. Ignore this node on next go around IFF
13631363
// we found a chosenNode to hedge read against.

0 commit comments

Comments
 (0)