You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by zs...@apache.org on 2016/02/03 18:50:33 UTC
spark git commit: [SPARK-12739][STREAMING] Details of batch in
Streaming tab uses two Duration columns
Repository: spark
Updated Branches:
refs/heads/master 138c300f9 -> e9eb248ed
[SPARK-12739][STREAMING] Details of batch in Streaming tab uses two Duration columns
I have clearly prefix the two 'Duration' columns in 'Details of Batch' Streaming tab as 'Output Op Duration' and 'Job Duration'
Author: Mario Briggs <ma...@in.ibm.com>
Author: mariobriggs <ma...@in.ibm.com>
Closes #11022 from mariobriggs/spark-12739.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e9eb248e
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e9eb248e
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e9eb248e
Branch: refs/heads/master
Commit: e9eb248edfa81d75f99c9afc2063e6b3d9ee7392
Parents: 138c300
Author: Mario Briggs <ma...@in.ibm.com>
Authored: Wed Feb 3 09:50:28 2016 -0800
Committer: Shixiong Zhu <sh...@databricks.com>
Committed: Wed Feb 3 09:50:28 2016 -0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/streaming/ui/BatchPage.scala | 4 ++--
.../test/scala/org/apache/spark/streaming/UISeleniumSuite.scala | 5 +++--
2 files changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/e9eb248e/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
----------------------------------------------------------------------
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
index 7635f79..81de07f 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala
@@ -37,10 +37,10 @@ private[ui] class BatchPage(parent: StreamingTab) extends WebUIPage("batch") {
private def columns: Seq[Node] = {
<th>Output Op Id</th>
<th>Description</th>
- <th>Duration</th>
+ <th>Output Op Duration</th>
<th>Status</th>
<th>Job Id</th>
- <th>Duration</th>
+ <th>Job Duration</th>
<th class="sorttable_nosort">Stages: Succeeded/Total</th>
<th class="sorttable_nosort">Tasks (for all stages): Succeeded/Total</th>
<th>Error</th>
http://git-wip-us.apache.org/repos/asf/spark/blob/e9eb248e/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala
----------------------------------------------------------------------
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala
index c4ecebc..96dd475 100644
--- a/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala
+++ b/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala
@@ -143,8 +143,9 @@ class UISeleniumSuite
summaryText should contain ("Total delay:")
findAll(cssSelector("""#batch-job-table th""")).map(_.text).toSeq should be {
- List("Output Op Id", "Description", "Duration", "Status", "Job Id", "Duration",
- "Stages: Succeeded/Total", "Tasks (for all stages): Succeeded/Total", "Error")
+ List("Output Op Id", "Description", "Output Op Duration", "Status", "Job Id",
+ "Job Duration", "Stages: Succeeded/Total", "Tasks (for all stages): Succeeded/Total",
+ "Error")
}
// Check we have 2 output op ids
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org