Victsm commented on a change in pull request #29855:
URL: https://github.com/apache/spark/pull/29855#discussion_r498949518
##########
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RetryingBlockFetcher.java
##########
@@ -99,18 +99,30 @@ void createAndStart(String[] blockIds,
BlockFetchingListener listener)
*/
private RetryingBlockFetchListener currentListener;
+ private final ErrorHandler errorHandler;
+
public RetryingBlockFetcher(
Review comment:
I commented earlier that we will rename BlockFetchingListener and
RetryingBlockFetcher, both of which are reused for block fetch/push, to
BlockTransferListener and RetryingBlockTransferor.
I plan to make a quick follow up PR for this naming change to limit the
number of files touched in this PR.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
