Repository: spark Updated Branches: refs/heads/master fd8c931a3 -> 2d686a19e
[SPARK-21155][WEBUI] Add (? running tasks) into Spark UI progress ## What changes were proposed in this pull request? Add metric on number of running tasks to status bar on Jobs / Active Jobs. ## How was this patch tested? Run a long running (1 minute) query in spark-shell and use localhost:4040 web UI to observe progress. See jira for screen snapshot. Author: Eric Vandenberg <ericvandenb...@fb.com> Closes #18369 from ericvandenbergfb/runningTasks. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2d686a19 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2d686a19 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2d686a19 Branch: refs/heads/master Commit: 2d686a19e341a31d976aa42228b7589f87dfd6c2 Parents: fd8c931 Author: Eric Vandenberg <ericvandenb...@fb.com> Authored: Wed Jun 28 09:26:33 2017 +0800 Committer: Wenchen Fan <wenc...@databricks.com> Committed: Wed Jun 28 09:26:33 2017 +0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/ui/UIUtils.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/2d686a19/core/src/main/scala/org/apache/spark/ui/UIUtils.scala ---------------------------------------------------------------------- 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 2610f67..ba798df 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 { <div class="progress"> <span style="text-align:center; position:absolute; width:100%; left:0;"> {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 { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org