Github user tgravescs commented on a diff in the pull request:
https://github.com/apache/spark/pull/22173#discussion_r218465817
--- Diff:
common/network-common/src/main/java/org/apache/spark/network/TransportContext.java
---
@@ -144,14 +163,21 @@ public TransportChannelHandler initializePipeline(
RpcHandler channelRpcHandler) {
try {
TransportChannelHandler channelHandler =
createChannelHandler(channel, channelRpcHandler);
- channel.pipeline()
+ ChunkFetchRequestHandler chunkFetchHandler =
+ createChunkFetchHandler(channelHandler, channelRpcHandler);
--- End diff --
fix spacing, only indented 2 spaces
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
