-
- Downloads
Revert "[SPARK-6028][Core]A new RPC implemetation based on the network module"
This reverts commit 084e4e12.
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 5 additions, 15 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 8 additions, 5 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 25 additions, 26 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpointNotFoundException.scala 0 additions, 22 deletions...a/org/apache/spark/rpc/RpcEndpointNotFoundException.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 2 additions, 5 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 0 additions, 218 deletions...rc/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
- core/src/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala 0 additions, 39 deletions...rc/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala 0 additions, 220 deletionscore/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcAddress.scala 0 additions, 56 deletions...in/scala/org/apache/spark/rpc/netty/NettyRpcAddress.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala 0 additions, 87 deletions...cala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala 0 additions, 504 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 1 addition, 5 deletionscore/src/main/scala/org/apache/spark/util/ThreadUtils.scala
- core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 6 additions, 4 deletions...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
- core/src/test/scala/org/apache/spark/SSLSampleConfigs.scala 0 additions, 2 deletionscore/src/test/scala/org/apache/spark/SSLSampleConfigs.scala
- core/src/test/scala/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala 4 additions, 2 deletions...a/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala
Loading
Please register or sign in to comment