diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala index 0040cf6dc5f53..d13c2c77205e0 100644 --- a/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala +++ b/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala @@ -115,7 +115,7 @@ private[v1] class OneStageResource(uiRoot: UIRoot) { def getStatusInfoUi(status: StageStatus, infos: Seq[StageInfo]): Seq[StageStatusInfoUi] = { infos.filter { _.stageId == stageId }.map { info => val ui = listener.stageIdToData.getOrElse((info.stageId, info.attemptId), - //this is an internal error -- we should always have uiData + // this is an internal error -- we should always have uiData throw new SparkException( s"no stage ui data found for stage: ${info.stageId}:${info.attemptId}") )