Skip to content

Commit

Permalink
Merge pull request alteryx#111 from kayousterhout/ui_name
Browse files Browse the repository at this point in the history
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 85e2cab)
Signed-off-by: Reynold Xin <rxin@apache.org>
  • Loading branch information
mateiz authored and rxin committed Oct 26, 2013
1 parent 7d47704 commit 3ec2f51
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,4 @@ class StageInfo(
val name = stage.name
val numPartitions = stage.numPartitions
val numTasks = stage.numTasks

override def toString = rddName
}
Original file line number Diff line number Diff line change
Expand Up @@ -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())
Expand Down

0 comments on commit 3ec2f51

Please sign in to comment.