xinglin commented on code in PR #6446:
URL: https://github.com/apache/hadoop/pull/6446#discussion_r1451271051
##########
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java:
##########
@@ -1270,17 +1314,16 @@ protected LocatedBlock refreshLocatedBlock(LocatedBlock
block)
* 'hedged' read if the first read is taking longer than configured amount of
* time. We then wait on which ever read returns first.
*/
- private void hedgedFetchBlockByteRange(LocatedBlock block, long start,
- long end, ByteBuffer buf, CorruptedBlocks corruptedBlocks)
- throws IOException {
+ private void hedgedFetchBlockByteRange(LocatedBlock block, long start, long
end, ByteBuffer buf,
+ CorruptedBlocks corruptedBlocks,
+ final Map<InetSocketAddress, List<IOException>> exceptionMap) throws
IOException {
final DfsClientConf conf = dfsClient.getConf();
ArrayList<Future<ByteBuffer>> futures = new ArrayList<>();
CompletionService<ByteBuffer> hedgedService =
new ExecutorCompletionService<>(dfsClient.getHedgedReadsThreadPool());
ArrayList<DatanodeInfo> ignored = new ArrayList<>();
ByteBuffer bb;
int len = (int) (end - start + 1);
- int hedgedReadId = 0;
Review Comment:
no longer used.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
