-
- Downloads
[SPARK-3281] Remove Netty specific code in BlockManager / shuffle
Netty functionality will be added back in subsequent PRs by using the BlockTransferService interface. Author: Reynold Xin <rxin@apache.org> Closes #2181 from rxin/SPARK-3281 and squashes the following commits: 5494b0e [Reynold Xin] Fix extra port. ff6d1e1 [Reynold Xin] [SPARK-3281] Remove Netty specific code in BlockManager.
Showing
- core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala 1 addition, 72 deletions...scala/org/apache/spark/storage/BlockFetcherIterator.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 3 additions, 38 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerId.scala 7 additions, 13 deletions.../main/scala/org/apache/spark/storage/BlockManagerId.scala
- core/src/main/scala/org/apache/spark/util/JsonProtocol.scala 2 additions, 4 deletionscore/src/main/scala/org/apache/spark/util/JsonProtocol.scala
- core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 15 additions, 15 deletions...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala 1 addition, 1 deletion.../scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockFetcherIteratorSuite.scala 8 additions, 8 deletions.../org/apache/spark/storage/BlockFetcherIteratorSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala 3 additions, 3 deletions...st/scala/org/apache/spark/storage/BlockManagerSuite.scala
- core/src/test/scala/org/apache/spark/storage/StorageStatusListenerSuite.scala 2 additions, 2 deletions...org/apache/spark/storage/StorageStatusListenerSuite.scala
- core/src/test/scala/org/apache/spark/storage/StorageSuite.scala 5 additions, 5 deletions...rc/test/scala/org/apache/spark/storage/StorageSuite.scala
- core/src/test/scala/org/apache/spark/ui/storage/StorageTabSuite.scala 1 addition, 1 deletion...t/scala/org/apache/spark/ui/storage/StorageTabSuite.scala
- core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala 10 additions, 7 deletions...src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala
- core/src/test/scala/org/apache/spark/util/JsonProtocolSuite.scala 6 additions, 9 deletions.../test/scala/org/apache/spark/util/JsonProtocolSuite.scala
Loading
Please register or sign in to comment