Skip to content

Commit af374ed

Browse files
zsxwingAndrew Or
authored andcommitted
[SPARK-7534] [CORE] [WEBUI] Fix the Stage table when a stage is missing
Just improved the Stage table when a stage is missing. Before: ![screen shot 2015-05-11 at 10 11 51 am](https://cloud.githubusercontent.com/assets/1000778/7570842/2ba37380-f7c8-11e4-9b5f-cf1a6264b2a4.png) After: ![screen shot 2015-05-11 at 10 26 09 am](https://cloud.githubusercontent.com/assets/1000778/7570848/33703152-f7c8-11e4-81a8-d53dd72d7b8d.png) Author: zsxwing <[email protected]> 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
1 parent 6523fb8 commit af374ed

File tree

1 file changed

+14
-1
lines changed

1 file changed

+14
-1
lines changed

core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,10 +121,23 @@ private[ui] class StageTableBase(
121121
<div>{stageDesc.getOrElse("")} {killLink} {nameLink} {details}</div>
122122
}
123123

124+
protected def missingStageRow(stageId: Int): Seq[Node] = {
125+
<td>{stageId}</td> ++
126+
{if (isFairScheduler) {<td>-</td>} else Seq.empty} ++
127+
<td>No data available for this stage</td> ++ // Description
128+
<td></td> ++ // Submitted
129+
<td></td> ++ // Duration
130+
<td></td> ++ // Tasks: Succeeded/Total
131+
<td></td> ++ // Input
132+
<td></td> ++ // Output
133+
<td></td> ++ // Shuffle Read
134+
<td></td> // Shuffle Write
135+
}
136+
124137
protected def stageRow(s: StageInfo): Seq[Node] = {
125138
val stageDataOption = listener.stageIdToData.get((s.stageId, s.attemptId))
126139
if (stageDataOption.isEmpty) {
127-
return <td>{s.stageId}</td><td>No data available for this stage</td>
140+
return missingStageRow(s.stageId)
128141
}
129142

130143
val stageData = stageDataOption.get

0 commit comments

Comments
 (0)