-
- Downloads
Merge pull request #93 from kayousterhout/ui_new_state
Show "GETTING_RESULTS" state in UI. This commit adds a set of calls using the SparkListener interface that indicate when a task is remotely fetching results, so that we can display this (potentially time-consuming) phase of execution to users through the UI.
No related branches found
No related tags found
Showing
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 8 additions, 0 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala 3 additions, 0 deletions.../scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala
- core/src/main/scala/org/apache/spark/scheduler/SparkListener.scala 9 additions, 0 deletions...main/scala/org/apache/spark/scheduler/SparkListener.scala
- core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala 2 additions, 0 deletions...n/scala/org/apache/spark/scheduler/SparkListenerBus.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskInfo.scala 20 additions, 0 deletions.../src/main/scala/org/apache/spark/scheduler/TaskInfo.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala 4 additions, 0 deletions...org/apache/spark/scheduler/cluster/ClusterScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManager.scala 6 additions, 0 deletions...pache/spark/scheduler/cluster/ClusterTaskSetManager.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/TaskResultGetter.scala 1 addition, 0 deletions...org/apache/spark/scheduler/cluster/TaskResultGetter.scala
- core/src/main/scala/org/apache/spark/ui/jobs/JobProgressListener.scala 7 additions, 1 deletion.../scala/org/apache/spark/ui/jobs/JobProgressListener.scala
- core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala 70 additions, 7 deletions...scala/org/apache/spark/scheduler/SparkListenerSuite.scala
Loading
Please register or sign in to comment