From 3ec2f51e3459503950f9678692706d2707a33a92 Mon Sep 17 00:00:00 2001 From: Matei Zaharia Date: Fri, 25 Oct 2013 14:46:06 -0700 Subject: [PATCH] Merge pull request #111 from kayousterhout/ui_name 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. @pwendell -- let me know if this change was intentional (cherry picked from commit 85e2cab6f68cbcb66bb348298463e2e86591d92d) Signed-off-by: Reynold Xin --- core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala | 2 -- core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala | 2 +- 2 files changed, 1 insertion(+), 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 37bb0891f6b14..93599dfdc85ff 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 2c29ea7d443f2..d7d0441c388fa 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 = - {s.toString} + {s.name} val description = listener.stageIdToDescription.get(s.stageId) .map(d =>
{d}
{nameLink}
).getOrElse(nameLink) val finishTime = s.completionTime.getOrElse(System.currentTimeMillis())