-
- Downloads
Added unit tests for ClusterTaskSetManager, and fix a bug found with
resetting locality level after a non-local launch
Showing
- core/src/main/scala/spark/scheduler/TaskLocation.scala 3 additions, 1 deletioncore/src/main/scala/spark/scheduler/TaskLocation.scala
- core/src/main/scala/spark/scheduler/TaskResult.scala 3 additions, 1 deletioncore/src/main/scala/spark/scheduler/TaskResult.scala
- core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala 16 additions, 11 deletions...scala/spark/scheduler/cluster/ClusterTaskSetManager.scala
- core/src/main/scala/spark/scheduler/cluster/TaskDescription.scala 3 additions, 0 deletions.../main/scala/spark/scheduler/cluster/TaskDescription.scala
- core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala 9 additions, 0 deletions...c/main/scala/spark/scheduler/cluster/TaskSetManager.scala
- core/src/main/scala/spark/scheduler/local/LocalTaskSetManager.scala 1 addition, 1 deletion...ain/scala/spark/scheduler/local/LocalTaskSetManager.scala
- core/src/main/scala/spark/util/Clock.scala 29 additions, 0 deletionscore/src/main/scala/spark/util/Clock.scala
- core/src/test/scala/spark/scheduler/cluster/ClusterSchedulerSuite.scala 7 additions, 14 deletions...scala/spark/scheduler/cluster/ClusterSchedulerSuite.scala
- core/src/test/scala/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala 273 additions, 0 deletions.../spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala
- core/src/test/scala/spark/scheduler/cluster/FakeTask.scala 26 additions, 0 deletionscore/src/test/scala/spark/scheduler/cluster/FakeTask.scala
- core/src/test/scala/spark/util/FakeClock.scala 26 additions, 0 deletionscore/src/test/scala/spark/util/FakeClock.scala
Loading
Please register or sign in to comment