-
- Downloads
[SPARK-9767] Remove ConnectionManager.
We introduced the Netty network module for shuffle in Spark 1.2, and has turned it on by default for 3 releases. The old ConnectionManager is difficult to maintain. If we merge the patch now, by the time it is released, it would be 1 yr for which ConnectionManager is off by default. It's time to remove it. Author: Reynold Xin <rxin@databricks.com> Closes #8161 from rxin/SPARK-9767.
Showing
- core/src/main/scala/org/apache/spark/SparkEnv.scala 1 addition, 10 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala 6 additions, 2 deletions...pache/spark/network/netty/NettyBlockTransferService.scala
- core/src/main/scala/org/apache/spark/network/nio/BlockMessage.scala 0 additions, 175 deletions...ain/scala/org/apache/spark/network/nio/BlockMessage.scala
- core/src/main/scala/org/apache/spark/network/nio/BlockMessageArray.scala 0 additions, 140 deletions...cala/org/apache/spark/network/nio/BlockMessageArray.scala
- core/src/main/scala/org/apache/spark/network/nio/BufferMessage.scala 0 additions, 114 deletions...in/scala/org/apache/spark/network/nio/BufferMessage.scala
- core/src/main/scala/org/apache/spark/network/nio/Connection.scala 0 additions, 619 deletions.../main/scala/org/apache/spark/network/nio/Connection.scala
- core/src/main/scala/org/apache/spark/network/nio/ConnectionId.scala 0 additions, 36 deletions...ain/scala/org/apache/spark/network/nio/ConnectionId.scala
- core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala 0 additions, 1157 deletions...cala/org/apache/spark/network/nio/ConnectionManager.scala
- core/src/main/scala/org/apache/spark/network/nio/ConnectionManagerId.scala 0 additions, 37 deletions...la/org/apache/spark/network/nio/ConnectionManagerId.scala
- core/src/main/scala/org/apache/spark/network/nio/Message.scala 0 additions, 114 deletions...src/main/scala/org/apache/spark/network/nio/Message.scala
- core/src/main/scala/org/apache/spark/network/nio/MessageChunk.scala 0 additions, 41 deletions...ain/scala/org/apache/spark/network/nio/MessageChunk.scala
- core/src/main/scala/org/apache/spark/network/nio/MessageChunkHeader.scala 0 additions, 83 deletions...ala/org/apache/spark/network/nio/MessageChunkHeader.scala
- core/src/main/scala/org/apache/spark/network/nio/NioBlockTransferService.scala 0 additions, 217 deletions...rg/apache/spark/network/nio/NioBlockTransferService.scala
- core/src/main/scala/org/apache/spark/network/nio/SecurityMessage.scala 0 additions, 160 deletions.../scala/org/apache/spark/network/nio/SecurityMessage.scala
- core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala 0 additions, 4 deletions...in/scala/org/apache/spark/serializer/KryoSerializer.scala
- core/src/test/scala/org/apache/spark/network/nio/ConnectionManagerSuite.scala 0 additions, 296 deletions...org/apache/spark/network/nio/ConnectionManagerSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerReplicationSuite.scala 3 additions, 3 deletions...g/apache/spark/storage/BlockManagerReplicationSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala 5 additions, 5 deletions...st/scala/org/apache/spark/storage/BlockManagerSuite.scala
- docs/configuration.md 0 additions, 11 deletionsdocs/configuration.md
- project/MimaExcludes.scala 630 additions, 627 deletionsproject/MimaExcludes.scala
Loading
Please register or sign in to comment