-
- Downloads
[SPARK-6602][Core] Update MapOutputTrackerMasterActor to MapOutputTrackerMasterEndpoint
This is the second PR for [SPARK-6602]. It updated MapOutputTrackerMasterActor and its unit tests. cc rxin Author: zsxwing <zsxwing@gmail.com> Closes #5371 from zsxwing/rpc-rewrite-part2 and squashes the following commits: fcf3816 [zsxwing] Fix the code style 4013a22 [zsxwing] Add doc for uncaught exceptions in RpcEnv 93c6c20 [zsxwing] Add an example of UnserializableException and add ErrorMonitor to monitor errors from Akka 134fe7b [zsxwing] Update MapOutputTrackerMasterActor to MapOutputTrackerMasterEndpoint
Showing
- core/src/main/scala/org/apache/spark/MapOutputTracker.scala 29 additions, 32 deletionscore/src/main/scala/org/apache/spark/MapOutputTracker.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 4 additions, 14 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 3 additions, 1 deletioncore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala 17 additions, 2 deletions...src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
- core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 55 additions, 45 deletions...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
- core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala 29 additions, 4 deletionscore/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala
- core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala 84 additions, 114 deletions...src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala
Loading
Please register or sign in to comment