From ae1bce01dd36130b3848096de59a8fdeb77d8025 Mon Sep 17 00:00:00 2001 From: Eric Vandenberg Date: Tue, 20 Jun 2017 14:28:52 -0700 Subject: [PATCH 1/2] [SPARK-21155][WEBUI] Add (? running tasks) into Spark UI progress --- core/src/main/scala/org/apache/spark/ui/UIUtils.scala | 1 + 1 file changed, 1 insertion(+) 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 2610f673d27f6..3bfecc138a7b5 100644 --- a/core/src/main/scala/org/apache/spark/ui/UIUtils.scala +++ b/core/src/main/scala/org/apache/spark/ui/UIUtils.scala @@ -356,6 +356,7 @@ private[spark] object UIUtils extends Logging {
{completed}/{total} + { if (started > 0) s"($started running)" } { if (failed > 0) s"($failed failed)" } { if (skipped > 0) s"($skipped skipped)" } { reasonToNumKilled.toSeq.sortBy(-_._2).map { From fea7cc949aa19644e6f386898a060d5cdb89b751 Mon Sep 17 00:00:00 2001 From: Eric Vandenberg Date: Thu, 22 Jun 2017 09:48:18 -0700 Subject: [PATCH 2/2] Only show running count if no skipped or failed counts. --- core/src/main/scala/org/apache/spark/ui/UIUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 3bfecc138a7b5..ba798df13c95d 100644 --- a/core/src/main/scala/org/apache/spark/ui/UIUtils.scala +++ b/core/src/main/scala/org/apache/spark/ui/UIUtils.scala @@ -356,7 +356,7 @@ private[spark] object UIUtils extends Logging {
{completed}/{total} - { if (started > 0) s"($started running)" } + { 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 {