[SPARK-26604][CORE][BACKPORT-2.4] remove channel registration in Tran…

…sportRequestHandler
apache · Mar 7, 2019 · a1709a6 · a1709a6
1 parent 10b38ab
commit a1709a6
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java b/...network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java
@@ -127,7 +127,6 @@ private void processFetchRequest(final ChunkFetchRequest req) {
     ManagedBuffer buf;
     try {
       streamManager.checkAuthorization(reverseClient, req.streamChunkId.streamId);
-      streamManager.registerChannel(channel, req.streamChunkId.streamId);
       buf = streamManager.getChunk(req.streamChunkId.streamId, req.streamChunkId.chunkIndex);
     } catch (Exception e) {
       logger.error(String.format("Error opening block %s for request from %s",