-
- Downloads
[SPARK-7997][CORE] Remove Akka from Spark Core and Streaming
- Remove Akka dependency from core. Note: the streaming-akka project still uses Akka. - Remove HttpFileServer - Remove Akka configs from SparkConf and SSLOptions - Rename `spark.akka.frameSize` to `spark.rpc.message.maxSize`. I think it's still worth to keep this config because using `DirectTaskResult` or `IndirectTaskResult` depends on it. - Update comments and docs Author: Shixiong Zhu <shixiong@databricks.com> Closes #10854 from zsxwing/remove-akka.
Showing
- core/pom.xml 4 additions, 13 deletionscore/pom.xml
- core/src/main/scala/org/apache/spark/ContextCleaner.scala 3 additions, 3 deletionscore/src/main/scala/org/apache/spark/ContextCleaner.scala
- core/src/main/scala/org/apache/spark/HttpFileServer.scala 0 additions, 91 deletionscore/src/main/scala/org/apache/spark/HttpFileServer.scala
- core/src/main/scala/org/apache/spark/MapOutputTracker.scala 4 additions, 3 deletionscore/src/main/scala/org/apache/spark/MapOutputTracker.scala
- core/src/main/scala/org/apache/spark/SSLOptions.scala 1 addition, 42 deletionscore/src/main/scala/org/apache/spark/SSLOptions.scala
- core/src/main/scala/org/apache/spark/SecurityManager.scala 4 additions, 15 deletionscore/src/main/scala/org/apache/spark/SecurityManager.scala
- core/src/main/scala/org/apache/spark/SparkConf.scala 11 additions, 21 deletionscore/src/main/scala/org/apache/spark/SparkConf.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 10 additions, 39 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/deploy/Client.scala 0 additions, 4 deletionscore/src/main/scala/org/apache/spark/deploy/Client.scala
- core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala 1 addition, 1 deletion.../src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
- core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala 2 additions, 10 deletions.../apache/spark/executor/CoarseGrainedExecutorBackend.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 4 additions, 4 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedClusterMessage.scala 0 additions, 1 deletion...spark/scheduler/cluster/CoarseGrainedClusterMessage.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala 7 additions, 8 deletions...ark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/SimrSchedulerBackend.scala 1 addition, 1 deletion...apache/spark/scheduler/cluster/SimrSchedulerBackend.scala
- core/src/main/scala/org/apache/spark/util/AkkaUtils.scala 0 additions, 139 deletionscore/src/main/scala/org/apache/spark/util/AkkaUtils.scala
- core/src/main/scala/org/apache/spark/util/RpcUtils.scala 12 additions, 0 deletionscore/src/main/scala/org/apache/spark/util/RpcUtils.scala
- core/src/test/scala/org/apache/spark/FileServerSuite.scala 0 additions, 264 deletionscore/src/test/scala/org/apache/spark/FileServerSuite.scala
- core/src/test/scala/org/apache/spark/HeartbeatReceiverSuite.scala 2 additions, 2 deletions.../test/scala/org/apache/spark/HeartbeatReceiverSuite.scala
- core/src/test/scala/org/apache/spark/LocalSparkContext.scala 1 addition, 1 deletioncore/src/test/scala/org/apache/spark/LocalSparkContext.scala
Loading
Please register or sign in to comment