-
- Downloads
[SPARK-6028] [CORE] Remerge #6457: new RPC implemetation and also pick #8905
This PR just reverted https://github.com/apache/spark/commit/02144d6745ec0a6d8877d969feb82139bd22437f to remerge #6457 and also included the commits in #8905. Author: zsxwing <zsxwing@gmail.com> Closes #8944 from zsxwing/SPARK-6028.
Showing
- core/src/main/scala/org/apache/spark/MapOutputTracker.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/MapOutputTracker.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 15 additions, 5 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/deploy/worker/Worker.scala
- core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala 5 additions, 8 deletions.../scala/org/apache/spark/deploy/worker/WorkerWatcher.scala
- core/src/main/scala/org/apache/spark/rpc/RpcCallContext.scala 1 addition, 1 deletion.../src/main/scala/org/apache/spark/rpc/RpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala 26 additions, 25 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpointNotFoundException.scala 22 additions, 0 deletions...a/org/apache/spark/rpc/RpcEndpointNotFoundException.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 3 additions, 2 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala 3 additions, 3 deletions...src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala 218 additions, 0 deletions...rc/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
- core/src/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala 39 additions, 0 deletions...rc/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala 227 additions, 0 deletionscore/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcAddress.scala 56 additions, 0 deletions...in/scala/org/apache/spark/rpc/netty/NettyRpcAddress.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala 87 additions, 0 deletions...cala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala 504 additions, 0 deletions...c/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveEndpoint.scala 3 additions, 3 deletions.../org/apache/spark/storage/BlockManagerSlaveEndpoint.scala
- core/src/main/scala/org/apache/spark/util/ThreadUtils.scala 5 additions, 1 deletioncore/src/main/scala/org/apache/spark/util/ThreadUtils.scala
- core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 4 additions, 6 deletions...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
- core/src/test/scala/org/apache/spark/SSLSampleConfigs.scala 2 additions, 0 deletionscore/src/test/scala/org/apache/spark/SSLSampleConfigs.scala
- core/src/test/scala/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala 2 additions, 4 deletions...a/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala
Loading
Please register or sign in to comment