Skip to content

Commit 10e37f6

Browse files
guoxiaolongsrowen
authored andcommitted
[UI][STREAMING] Modify the title, 'Records' instead of 'Input Size'
## What changes were proposed in this pull request? Spark Streaming is processing data should be record, so the title should be 'Records', and should not be 'Input Size'. Fix before: ![1](https://user-images.githubusercontent.com/26266482/30099599-c64d4a8a-9318-11e7-8a8d-1ca99b409323.png) Fix after: ![2](https://user-images.githubusercontent.com/26266482/30099609-cd4df7d0-9318-11e7-8a27-dbaec6797bb1.png) ## How was this patch tested? manual tests Please review http://spark.apache.org/contributing.html before opening a pull request. Author: guoxiaolong <[email protected]> Closes apache#19144 from guoxiaolongzte/streamingUI.
1 parent 27fc536 commit 10e37f6

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ private[ui] abstract class BatchTableBase(tableId: String, batchInterval: Long)
2525

2626
protected def columns: Seq[Node] = {
2727
<th>Batch Time</th>
28-
<th>Input Size</th>
28+
<th>Records</th>
2929
<th>Scheduling Delay
3030
{SparkUIUtils.tooltip("Time taken by Streaming scheduler to submit jobs of a batch", "top")}
3131
</th>

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,11 +121,11 @@ class UISeleniumSuite
121121
h4Text.exists(_.matches("Completed Batches \\(last \\d+ out of \\d+\\)")) should be (true)
122122

123123
findAll(cssSelector("""#active-batches-table th""")).map(_.text).toSeq should be {
124-
List("Batch Time", "Input Size", "Scheduling Delay (?)", "Processing Time (?)",
124+
List("Batch Time", "Records", "Scheduling Delay (?)", "Processing Time (?)",
125125
"Output Ops: Succeeded/Total", "Status")
126126
}
127127
findAll(cssSelector("""#completed-batches-table th""")).map(_.text).toSeq should be {
128-
List("Batch Time", "Input Size", "Scheduling Delay (?)", "Processing Time (?)",
128+
List("Batch Time", "Records", "Scheduling Delay (?)", "Processing Time (?)",
129129
"Total Delay (?)", "Output Ops: Succeeded/Total")
130130
}
131131

0 commit comments

Comments
 (0)