From 1c6d332327de03a631918860d200fc69e056dfa8 Mon Sep 17 00:00:00 2001 From: scwf Date: Fri, 21 Mar 2014 11:23:42 +0800 Subject: [PATCH 1/3] Update StageTable.scala fix the problem that the numbers on progress bar move along with task progress until invisible --- .../main/scala/org/apache/spark/ui/jobs/StageTable.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala index 68fef5234c9ab..80705c3ffefb9 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala @@ -60,11 +60,11 @@ private[ui] class StageTable(stages: Seq[StageInfo], parent: JobProgressUI) { private def makeProgressBar(started: Int, completed: Int, failed: String, total: Int): Seq[Node] = { - val completeWidth = "width: %s%%".format((completed.toDouble/total)*100) - val startWidth = "width: %s%%".format((started.toDouble/total)*100) + val completeWidth = "width: %s%%; position: absolute;".format((completed.toDouble/total)*100) + val startWidth = "width: %s%%; left: %s%%; position: absolute;".format((started.toDouble/total)*100)
- + {completed}/{total} {failed}
From 2d6f4849a37015d06b112b4f8538b9bac1c2be43 Mon Sep 17 00:00:00 2001 From: scwf Date: Fri, 21 Mar 2014 13:20:30 +0800 Subject: [PATCH 2/3] Update StageTable.scala updated --- .../main/scala/org/apache/spark/ui/jobs/StageTable.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala index 80705c3ffefb9..32128e228ca4f 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala @@ -60,8 +60,10 @@ private[ui] class StageTable(stages: Seq[StageInfo], parent: JobProgressUI) { private def makeProgressBar(started: Int, completed: Int, failed: String, total: Int): Seq[Node] = { - val completeWidth = "width: %s%%; position: absolute;".format((completed.toDouble/total)*100) - val startWidth = "width: %s%%; left: %s%%; position: absolute;".format((started.toDouble/total)*100) + val startPct = (started.toDouble/total)*100 + val completePct = (completed.toDouble/total)*100 + val completeWidth = "width: %s%%; position: absolute;".format(completePct) + val startWidth = "width: %s%%; left: %s%%; position: absolute;".format(startPct,completePct)
From a66094dbbd7f6e992c7996e93885947b0ef786fd Mon Sep 17 00:00:00 2001 From: scwf Date: Fri, 21 Mar 2014 13:38:21 +0800 Subject: [PATCH 3/3] Update StageTable.scala --- core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala index 32128e228ca4f..488af0a951af9 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala @@ -63,7 +63,7 @@ private[ui] class StageTable(stages: Seq[StageInfo], parent: JobProgressUI) { val startPct = (started.toDouble/total)*100 val completePct = (completed.toDouble/total)*100 val completeWidth = "width: %s%%; position: absolute;".format(completePct) - val startWidth = "width: %s%%; left: %s%%; position: absolute;".format(startPct,completePct) + val startWidth = "width: %s%%; left: %s%%; position: absolute;".format(startPct, completePct)