-
- Downloads
Added a unit test for local-cluster mode and simplified some of the code involved in that
Showing
- core/src/main/scala/spark/SparkContext.scala 4 additions, 4 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/broadcast/HttpBroadcast.scala 6 additions, 3 deletionscore/src/main/scala/spark/broadcast/HttpBroadcast.scala
- core/src/main/scala/spark/deploy/LocalSparkCluster.scala 16 additions, 27 deletionscore/src/main/scala/spark/deploy/LocalSparkCluster.scala
- core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala 18 additions, 11 deletionscore/src/main/scala/spark/deploy/worker/ExecutorRunner.scala
- core/src/main/scala/spark/deploy/worker/Worker.scala 4 additions, 0 deletionscore/src/main/scala/spark/deploy/worker/Worker.scala
- core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala 3 additions, 3 deletions...spark/scheduler/cluster/SparkDeploySchedulerBackend.scala
- core/src/test/scala/spark/DistributedSuite.scala 68 additions, 0 deletionscore/src/test/scala/spark/DistributedSuite.scala
- run 1 addition, 0 deletionsrun
Loading
Please register or sign in to comment