Skip to content

Commit e9eb248

Browse files
mariobriggszsxwing
authored andcommitted
[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 <[email protected]> Author: mariobriggs <[email protected]> Closes #11022 from mariobriggs/spark-12739.
1 parent 138c300 commit e9eb248

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,10 @@ private[ui] class BatchPage(parent: StreamingTab) extends WebUIPage("batch") {
3737
private def columns: Seq[Node] = {
3838
<th>Output Op Id</th>
3939
<th>Description</th>
40-
<th>Duration</th>
40+
<th>Output Op Duration</th>
4141
<th>Status</th>
4242
<th>Job Id</th>
43-
<th>Duration</th>
43+
<th>Job Duration</th>
4444
<th class="sorttable_nosort">Stages: Succeeded/Total</th>
4545
<th class="sorttable_nosort">Tasks (for all stages): Succeeded/Total</th>
4646
<th>Error</th>

streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,8 +143,9 @@ class UISeleniumSuite
143143
summaryText should contain ("Total delay:")
144144

145145
findAll(cssSelector("""#batch-job-table th""")).map(_.text).toSeq should be {
146-
List("Output Op Id", "Description", "Duration", "Status", "Job Id", "Duration",
147-
"Stages: Succeeded/Total", "Tasks (for all stages): Succeeded/Total", "Error")
146+
List("Output Op Id", "Description", "Output Op Duration", "Status", "Job Id",
147+
"Job Duration", "Stages: Succeeded/Total", "Tasks (for all stages): Succeeded/Total",
148+
"Error")
148149
}
149150

150151
// Check we have 2 output op ids

0 commit comments

Comments
 (0)