diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-25 12:39:46 -0700 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-26 22:18:39 -0700 |
| commit | ae22b4dd99c7ac9b48a5859c26f0a2c708dccd65 (patch) | |
| tree | 70dcb4b842ed9f59ccee36b2e890e891f99cb26b /core | |
| parent | 1dc776b863663af713920d18cecaf57762c2fd77 (diff) | |
| download | spark-ae22b4dd99c7ac9b48a5859c26f0a2c708dccd65.tar.gz spark-ae22b4dd99c7ac9b48a5859c26f0a2c708dccd65.tar.bz2 spark-ae22b4dd99c7ac9b48a5859c26f0a2c708dccd65.zip | |
Display both task ID and task index in UI
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala index 0dd57235e3..35b5d5fd59 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala @@ -83,8 +83,8 @@ private[spark] class StagePage(parent: JobProgressUI) { </div> val taskHeaders: Seq[String] = - Seq("Task ID", "Status", "Locality Level", "Executor", "Launch Time", "Duration") ++ - Seq("GC Time") ++ + Seq("Task Index", "Task ID", "Status", "Locality Level", "Executor", "Launch Time") ++ + Seq("Duration", "GC Time") ++ {if (hasShuffleRead) Seq("Shuffle Read") else Nil} ++ {if (hasShuffleWrite) Seq("Write Time", "Shuffle Write") else Nil} ++ Seq("Errors") @@ -153,6 +153,7 @@ private[spark] class StagePage(parent: JobProgressUI) { val gcTime = metrics.map(m => m.jvmGCTime).getOrElse(0L) <tr> + <td>{info.index}</td> <td>{info.taskId}</td> <td>{info.status}</td> <td>{info.taskLocality}</td> |