You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by do...@apache.org on 2018/09/25 03:04:14 UTC
spark git commit: [SPARK-25503][CORE][WEBUI] Total task message in
stage page is ambiguous
Repository: spark
Updated Branches:
refs/heads/master 2c9ffda1b -> 615792da4
[SPARK-25503][CORE][WEBUI] Total task message in stage page is ambiguous
## What changes were proposed in this pull request?
Test steps :
1) bin/spark-shell --conf spark.ui.retainedTasks=10
2) val rdd = sc.parallelize(1 to 1000, 1000)
3) rdd.count
Stage page tab in the UI will display 10 tasks, but display message is wrong. It should reverse.
**Before fix :**
**After fix**
## How was this patch tested?
Manually tested
Closes #22525 from shahidki31/SparkUI.
Authored-by: Shahid <sh...@gmail.com>
Signed-off-by: Dongjoon Hyun <do...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/615792da
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/615792da
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/615792da
Branch: refs/heads/master
Commit: 615792da42b3ee3c5f623c869fada17a3aa92884
Parents: 2c9ffda
Author: Shahid <sh...@gmail.com>
Authored: Mon Sep 24 20:03:52 2018 -0700
Committer: Dongjoon Hyun <do...@apache.org>
Committed: Mon Sep 24 20:03:52 2018 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/615792da/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
index fd6a298..7428bbe 100644
--- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
+++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
@@ -133,7 +133,7 @@ private[ui] class StagePage(parent: StagesTab, store: AppStatusStore) extends We
val totalTasksNumStr = if (totalTasks == storedTasks) {
s"$totalTasks"
} else {
- s"$storedTasks, showing ${totalTasks}"
+ s"$totalTasks, showing $storedTasks"
}
val summary =
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org