diff --git a/core/src/main/scala/org/apache/spark/ui/UIUtils.scala b/core/src/main/scala/org/apache/spark/ui/UIUtils.scala index c3dc459b0f88e..fff6ec4f5b170 100644 --- a/core/src/main/scala/org/apache/spark/ui/UIUtils.scala +++ b/core/src/main/scala/org/apache/spark/ui/UIUtils.scala @@ -449,16 +449,24 @@ private[spark] object UIUtils extends Logging { val startRatio = if (total == 0) 0.0 else (boundedStarted.toDouble / total) * 100 val startWidth = "width: %s%%".format(startRatio) + val killTaskReasonText = reasonToNumKilled.toSeq.sortBy(-_._2).map { + case (reason, count) => s" ($count killed: $reason)" + }.mkString + val progressTitle = s"$completed/$total" + { + if (started > 0) s" ($started running)" else "" + } + { + if (failed > 0) s" ($failed failed)" else "" + } + { + if (skipped > 0) s" ($skipped skipped)" else "" + } + killTaskReasonText +
- + {completed}/{total} { if (failed == 0 && skipped == 0 && started > 0) s"($started running)" } { if (failed > 0) s"($failed failed)" } { if (skipped > 0) s"($skipped skipped)" } - { reasonToNumKilled.toSeq.sortBy(-_._2).map { - case (reason, count) => s"($count killed: $reason)" - } - } + { killTaskReasonText }