-
- Downloads
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).
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
Loading
Please register or sign in to comment