-
- Downloads
[SPARK-6602][Core]Replace Akka Serialization with Spark Serializer
Replace Akka Serialization with Spark Serializer and add unit tests. Author: zsxwing <zsxwing@gmail.com> Closes #7159 from zsxwing/remove-akka-serialization and squashes the following commits: fc0fca3 [zsxwing] Merge branch 'master' into remove-akka-serialization cf81a58 [zsxwing] Fix the code style 73251c6 [zsxwing] Add test scope 9ef4af9 [zsxwing] Add AkkaRpcEndpointRef.hashCode 433115c [zsxwing] Remove final be3edb0 [zsxwing] Support deserializing RpcEndpointRef ecec410 [zsxwing] Replace Akka Serialization with Spark Serializer
Showing
- core/pom.xml 5 additions, 0 deletionscore/pom.xml
- core/src/main/scala/org/apache/spark/deploy/master/FileSystemPersistenceEngine.scala 19 additions, 16 deletions...che/spark/deploy/master/FileSystemPersistenceEngine.scala
- core/src/main/scala/org/apache/spark/deploy/master/Master.scala 7 additions, 11 deletions...rc/main/scala/org/apache/spark/deploy/master/Master.scala
- core/src/main/scala/org/apache/spark/deploy/master/PersistenceEngine.scala 6 additions, 2 deletions...la/org/apache/spark/deploy/master/PersistenceEngine.scala
- core/src/main/scala/org/apache/spark/deploy/master/RecoveryModeFactory.scala 4 additions, 5 deletions.../org/apache/spark/deploy/master/RecoveryModeFactory.scala
- core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperPersistenceEngine.scala 8 additions, 8 deletions...ache/spark/deploy/master/ZooKeeperPersistenceEngine.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 6 additions, 0 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala 13 additions, 1 deletion...src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
- core/src/test/scala/org/apache/spark/deploy/master/CustomRecoveryModeFactory.scala 13 additions, 18 deletions...pache/spark/deploy/master/CustomRecoveryModeFactory.scala
- core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala 1 addition, 1 deletion...st/scala/org/apache/spark/deploy/master/MasterSuite.scala
- core/src/test/scala/org/apache/spark/deploy/master/PersistenceEngineSuite.scala 126 additions, 0 deletions...g/apache/spark/deploy/master/PersistenceEngineSuite.scala
- pom.xml 6 additions, 0 deletionspom.xml
Loading
Please register or sign in to comment