diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-25 12:00:09 -0700 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-25 12:00:09 -0700 |
| commit | a9c8d83aafe4990d3298b395715a98c107dcd667 (patch) | |
| tree | dba381516464dc60b0971c96ccbd448a4c1c54cc /core | |
| parent | 1dc776b863663af713920d18cecaf57762c2fd77 (diff) | |
| download | spark-a9c8d83aafe4990d3298b395715a98c107dcd667.tar.gz spark-a9c8d83aafe4990d3298b395715a98c107dcd667.tar.bz2 spark-a9c8d83aafe4990d3298b395715a98c107dcd667.zip | |
Properly display the name of a stage in the UI.
This fixes a bug introduced by the fix for SPARK-940, which
changed the UI to display the RDD name rather than the stage
name. As a result, no name for the stage was shown when
using the Spark shell, which meant that there was no way to
click on the stage to see more details (e.g., the running
tasks). This commit changes the UI back to using the
stage name.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala | 2 | ||||
| -rw-r--r-- | core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala | 2 |
2 files changed, 1 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala b/core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala index 37bb0891f6..93599dfdc8 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala @@ -33,6 +33,4 @@ class StageInfo( val name = stage.name val numPartitions = stage.numPartitions val numTasks = stage.numTasks - - override def toString = rddName } diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala index 2c29ea7d44..d7d0441c38 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala @@ -99,7 +99,7 @@ private[spark] class StageTable(val stages: Seq[StageInfo], val parent: JobProgr val poolName = listener.stageIdToPool.get(s.stageId) val nameLink = - <a href={"%s/stages/stage?id=%s".format(UIUtils.prependBaseUri(),s.stageId)}>{s.toString}</a> + <a href={"%s/stages/stage?id=%s".format(UIUtils.prependBaseUri(),s.stageId)}>{s.name}</a> val description = listener.stageIdToDescription.get(s.stageId) .map(d => <div><em>{d}</em></div><div>{nameLink}</div>).getOrElse(nameLink) val finishTime = s.completionTime.getOrElse(System.currentTimeMillis()) |