Repository: spark Updated Branches: refs/heads/master 640f63b95 -> 8a4edecc4
[SPARK-7534] [CORE] [WEBUI] Fix the Stage table when a stage is missing Just improved the Stage table when a stage is missing. Before:  After:  Author: zsxwing <zsxw...@gmail.com> Closes #6061 from zsxwing/SPARK-7534 and squashes the following commits: 09fe862 [zsxwing] Leave it blank rather than '-' 6299197 [zsxwing] Fix the Stage table when a stage is missing Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/8a4edecc Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/8a4edecc Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/8a4edecc Branch: refs/heads/master Commit: 8a4edecc483490da4fce406ac3b401860834ac1e Parents: 640f63b Author: zsxwing <zsxw...@gmail.com> Authored: Tue May 12 01:34:33 2015 -0700 Committer: Andrew Or <and...@databricks.com> Committed: Tue May 12 01:34:33 2015 -0700 ---------------------------------------------------------------------- .../scala/org/apache/spark/ui/jobs/StageTable.scala | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/8a4edecc/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala ---------------------------------------------------------------------- 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 a33243d..82ba561 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 @@ -121,10 +121,23 @@ private[ui] class StageTableBase( <div>{stageDesc.getOrElse("")} {killLink} {nameLink} {details}</div> } + protected def missingStageRow(stageId: Int): Seq[Node] = { + <td>{stageId}</td> ++ + {if (isFairScheduler) {<td>-</td>} else Seq.empty} ++ + <td>No data available for this stage</td> ++ // Description + <td></td> ++ // Submitted + <td></td> ++ // Duration + <td></td> ++ // Tasks: Succeeded/Total + <td></td> ++ // Input + <td></td> ++ // Output + <td></td> ++ // Shuffle Read + <td></td> // Shuffle Write + } + protected def stageRow(s: StageInfo): Seq[Node] = { val stageDataOption = listener.stageIdToData.get((s.stageId, s.attemptId)) if (stageDataOption.isEmpty) { - return <td>{s.stageId}</td><td>No data available for this stage</td> + return missingStageRow(s.stageId) } val stageData = stageDataOption.get --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
