Github user tgravescs commented on a diff in the pull request:
https://github.com/apache/spark/pull/22173#discussion_r218924588
--- Diff:
common/network-common/src/main/java/org/apache/spark/network/TransportContext.java
---
@@ -173,5 +213,14 @@ private TransportChannelHandler
createChannelHandler(Channel channel, RpcHandler
conf.connectionTimeoutMs(), closeIdleConnections);
}
+ /**
+ * Creates the dedicated ChannelHandler for ChunkFetchRequest messages.
+ */
+ private ChunkFetchRequestHandler
createChunkFetchHandler(TransportChannelHandler channelHandler,
+ RpcHandler rpcHandler) {
+ return new ChunkFetchRequestHandler(channelHandler.getClient(),
+ rpcHandler.getStreamManager(), conf.maxChunksBeingTransferred());
--- End diff --
identation 2 spaces inside return
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
