-
- Downloads
Merge pull request #67 from kayousterhout/remove_tsl
Removed TaskSchedulerListener interface. The interface was used only by the DAG scheduler (so it wasn't necessary to define the additional interface), and the naming makes it very confusing when reading the code (because "listener" was used to describe the DAG scheduler, rather than SparkListeners, which implement a nearly-identical interface but serve a different function). @mateiz - is there a reason for this interface that I'm missing?
Showing
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 7 additions, 7 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala 3 additions, 4 deletions...main/scala/org/apache/spark/scheduler/TaskScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerListener.scala 0 additions, 44 deletions...la/org/apache/spark/scheduler/TaskSchedulerListener.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala 7 additions, 7 deletions...org/apache/spark/scheduler/cluster/ClusterScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManager.scala 11 additions, 10 deletions...pache/spark/scheduler/cluster/ClusterTaskSetManager.scala
- core/src/main/scala/org/apache/spark/scheduler/local/LocalScheduler.scala 3 additions, 3 deletions...ala/org/apache/spark/scheduler/local/LocalScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/local/LocalTaskSetManager.scala 6 additions, 5 deletions...rg/apache/spark/scheduler/local/LocalTaskSetManager.scala
- core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala 1 addition, 1 deletion.../scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala 25 additions, 24 deletions.../spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala
Loading
Please register or sign in to comment