-
- Downloads
Enhance job ui in spark ui system with adding pool information
Showing
- core/src/main/scala/spark/SparkContext.scala 15 additions, 2 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/scheduler/DAGScheduler.scala 2 additions, 2 deletionscore/src/main/scala/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/spark/scheduler/JobLogger.scala 1 addition, 1 deletioncore/src/main/scala/spark/scheduler/JobLogger.scala
- core/src/main/scala/spark/scheduler/SparkListener.scala 1 addition, 1 deletioncore/src/main/scala/spark/scheduler/SparkListener.scala
- core/src/main/scala/spark/scheduler/TaskScheduler.scala 7 additions, 0 deletionscore/src/main/scala/spark/scheduler/TaskScheduler.scala
- core/src/main/scala/spark/scheduler/cluster/ClusterScheduler.scala 6 additions, 5 deletions...main/scala/spark/scheduler/cluster/ClusterScheduler.scala
- core/src/main/scala/spark/scheduler/cluster/ClusterTaskSetManager.scala 2 additions, 2 deletions...scala/spark/scheduler/cluster/ClusterTaskSetManager.scala
- core/src/main/scala/spark/scheduler/cluster/Schedulable.scala 5 additions, 1 deletion.../src/main/scala/spark/scheduler/cluster/Schedulable.scala
- core/src/main/scala/spark/scheduler/cluster/SchedulingMode.scala 2 additions, 2 deletions...c/main/scala/spark/scheduler/cluster/SchedulingMode.scala
- core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala 1 addition, 0 deletions...c/main/scala/spark/scheduler/cluster/TaskSetManager.scala
- core/src/main/scala/spark/scheduler/local/LocalScheduler.scala 5 additions, 5 deletions...src/main/scala/spark/scheduler/local/LocalScheduler.scala
- core/src/main/scala/spark/scheduler/local/LocalTaskSetManager.scala 1 addition, 0 deletions...ain/scala/spark/scheduler/local/LocalTaskSetManager.scala
- core/src/main/scala/spark/ui/jobs/IndexPage.scala 33 additions, 88 deletionscore/src/main/scala/spark/ui/jobs/IndexPage.scala
- core/src/main/scala/spark/ui/jobs/JobProgressListener.scala 140 additions, 0 deletionscore/src/main/scala/spark/ui/jobs/JobProgressListener.scala
- core/src/main/scala/spark/ui/jobs/JobProgressUI.scala 23 additions, 89 deletionscore/src/main/scala/spark/ui/jobs/JobProgressUI.scala
- core/src/main/scala/spark/ui/jobs/PoolPage.scala 38 additions, 0 deletionscore/src/main/scala/spark/ui/jobs/PoolPage.scala
- core/src/main/scala/spark/ui/jobs/PoolTable.scala 98 additions, 0 deletionscore/src/main/scala/spark/ui/jobs/PoolTable.scala
- core/src/main/scala/spark/ui/jobs/StageTable.scala 143 additions, 0 deletionscore/src/main/scala/spark/ui/jobs/StageTable.scala
- core/src/test/scala/spark/scheduler/DAGSchedulerSuite.scala 6 additions, 0 deletionscore/src/test/scala/spark/scheduler/DAGSchedulerSuite.scala
- core/src/test/scala/spark/scheduler/JobLoggerSuite.scala 1 addition, 1 deletioncore/src/test/scala/spark/scheduler/JobLoggerSuite.scala
Loading
Please register or sign in to comment