-
- Downloads
More scheduling fixes:
- Added periodic revival of offers in StandaloneSchedulerBackend - Replaced task scheduling aggression with multi-level delay scheduling in ClusterTaskSetManager - Fixed ZippedRDD preferred locations because they can't currently be process-local - Fixed some uses of hostPort
Showing
- core/src/main/scala/spark/SparkEnv.scala 2 additions, 17 deletionscore/src/main/scala/spark/SparkEnv.scala
- core/src/main/scala/spark/Utils.scala 2 additions, 29 deletionscore/src/main/scala/spark/Utils.scala
- core/src/main/scala/spark/deploy/DeployMessage.scala 1 addition, 0 deletionscore/src/main/scala/spark/deploy/DeployMessage.scala
- core/src/main/scala/spark/deploy/worker/ExecutorRunner.scala 2 additions, 4 deletionscore/src/main/scala/spark/deploy/worker/ExecutorRunner.scala
- core/src/main/scala/spark/deploy/worker/Worker.scala 1 addition, 1 deletioncore/src/main/scala/spark/deploy/worker/Worker.scala
- core/src/main/scala/spark/rdd/CartesianRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/rdd/CartesianRDD.scala
- core/src/main/scala/spark/rdd/ZippedPartitionsRDD.scala 9 additions, 23 deletionscore/src/main/scala/spark/rdd/ZippedPartitionsRDD.scala
- core/src/main/scala/spark/rdd/ZippedRDD.scala 6 additions, 17 deletionscore/src/main/scala/spark/rdd/ZippedRDD.scala
- core/src/main/scala/spark/scheduler/cluster/ClusterScheduler.scala 1 addition, 67 deletions...main/scala/spark/scheduler/cluster/ClusterScheduler.scala
- core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala 87 additions, 29 deletions...scala/spark/scheduler/cluster/ClusterTaskSetManager.scala
- core/src/main/scala/spark/scheduler/cluster/StandaloneSchedulerBackend.scala 5 additions, 2 deletions.../spark/scheduler/cluster/StandaloneSchedulerBackend.scala
Loading
Please register or sign in to comment