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 <mario.bri...@in.ibm.com> Author: mariobriggs <mariobri...@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 <mario.bri...@in.ibm.com> Authored: Wed Feb 3 09:50:28 2016 -0800 Committer: Shixiong Zhu <shixi...@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-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org