You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2017/06/28 01:26:39 UTC
spark git commit: [SPARK-21155][WEBUI] Add (? running tasks) into
Spark UI progress
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 <er...@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 <er...@fb.com>
Authored: Wed Jun 28 09:26:33 2017 +0800
Committer: Wenchen Fan <we...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org