Commit 276c37a5 authored 11 years ago by Prashant Sharma

Akka 2.2 migration

parent 69fd42ae

No related branches found

No related tags found

No related merge requests found

Hide whitespace changes

Inline Side-by-side

Showing

core/src/main/scala/org/apache/spark/SparkEnv.scala 1 addition, 1 deletion

core/src/main/scala/org/apache/spark/SparkEnv.scala
core/src/main/scala/org/apache/spark/deploy/client/Client.scala 4 additions, 6 deletions

...rc/main/scala/org/apache/spark/deploy/client/Client.scala
core/src/main/scala/org/apache/spark/deploy/master/Master.scala 23 additions, 8 deletions

...rc/main/scala/org/apache/spark/deploy/master/Master.scala
core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala 6 additions, 6 deletions

...rc/main/scala/org/apache/spark/deploy/worker/Worker.scala
core/src/main/scala/org/apache/spark/executor/Executor.scala 1 addition, 1 deletion

core/src/main/scala/org/apache/spark/executor/Executor.scala
core/src/main/scala/org/apache/spark/executor/StandaloneExecutorBackend.scala 21 additions, 9 deletions

...org/apache/spark/executor/StandaloneExecutorBackend.scala
core/src/main/scala/org/apache/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala 1 addition, 1 deletion

...spark/scheduler/cluster/SparkDeploySchedulerBackend.scala
core/src/main/scala/org/apache/spark/scheduler/cluster/StandaloneSchedulerBackend.scala 6 additions, 6 deletions

.../spark/scheduler/cluster/StandaloneSchedulerBackend.scala
core/src/main/scala/org/apache/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala 1 addition, 1 deletion

...e/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala
core/src/main/scala/org/apache/spark/util/AkkaUtils.scala 11 additions, 12 deletions

core/src/main/scala/org/apache/spark/util/AkkaUtils.scala
core/src/test/scala/org/apache/spark/DistributedSuite.scala 1 addition, 1 deletion

core/src/test/scala/org/apache/spark/DistributedSuite.scala
core/src/test/scala/org/apache/spark/DriverSuite.scala 1 addition, 1 deletion

core/src/test/scala/org/apache/spark/DriverSuite.scala
core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 1 addition, 1 deletion

...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala 1 addition, 1 deletion

.../org/apache/spark/streaming/examples/ActorWordCount.scala
examples/src/main/scala/org/apache/spark/streaming/examples/ZeroMQWordCount.scala 5 additions, 3 deletions

...org/apache/spark/streaming/examples/ZeroMQWordCount.scala
project/SparkBuild.scala 9 additions, 9 deletions

project/SparkBuild.scala
streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 3 additions, 2 deletions

...n/scala/org/apache/spark/streaming/StreamingContext.scala
streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 4 additions, 3 deletions

...pache/spark/streaming/api/java/JavaStreamingContext.scala
streaming/src/main/scala/org/apache/spark/streaming/dstream/NetworkInputDStream.scala 1 addition, 1 deletion

.../apache/spark/streaming/dstream/NetworkInputDStream.scala
streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala 2 additions, 2 deletions

.../org/apache/spark/streaming/receivers/ActorReceiver.scala

with 103 additions and 75 deletions

Please register or to comment