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 a33243d4252bf..82ba561eefb16 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(
{stageDesc.getOrElse("")} {killLink} {nameLink} {details}
}
+ protected def missingStageRow(stageId: Int): Seq[Node] = {
+ {stageId} | ++
+ {if (isFairScheduler) {- | } else Seq.empty} ++
+ No data available for this stage | ++ // Description
+ | ++ // Submitted
+ | ++ // Duration
+ | ++ // Tasks: Succeeded/Total
+ | ++ // Input
+ | ++ // Output
+ | ++ // Shuffle Read
+ | // Shuffle Write
+ }
+
protected def stageRow(s: StageInfo): Seq[Node] = {
val stageDataOption = listener.stageIdToData.get((s.stageId, s.attemptId))
if (stageDataOption.isEmpty) {
- return {s.stageId} | No data available for this stage |
+ return missingStageRow(s.stageId)
}
val stageData = stageDataOption.get