You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2018/02/13 17:39:36 UTC
spark git commit: [SPARK-23382][WEB-UI] Spark Streaming ui about the
contents of the for need to have hidden and show features,
when the table records very much.
Repository: spark
Updated Branches:
refs/heads/master 091a000d2 -> bd2473172
[SPARK-23382][WEB-UI] Spark Streaming ui about the contents of the for need to have hidden and show features, when the table records very much.
## What changes were proposed in this pull request?
Spark Streaming ui about the contents of the for need to have hidden and show features, when the table records very much.
please refer to https://github.com/apache/spark/pull/20216
fix after:
## How was this patch tested?
(Please explain how this patch was tested. E.g. unit tests, integration tests, manual tests)
(If this patch involves UI changes, please attach a screenshot; otherwise, remove this)
Please review http://spark.apache.org/contributing.html before opening a pull request.
Author: guoxiaolong <gu...@zte.com.cn>
Closes #20570 from guoxiaolongzte/SPARK-23382.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/bd247317
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/bd247317
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/bd247317
Branch: refs/heads/master
Commit: bd24731722a9142c90cf3d76008115f308203844
Parents: 091a000
Author: guoxiaolong <gu...@zte.com.cn>
Authored: Tue Feb 13 11:39:33 2018 -0600
Committer: Sean Owen <so...@cloudera.com>
Committed: Tue Feb 13 11:39:33 2018 -0600
----------------------------------------------------------------------
.../org/apache/spark/ui/static/webui.js | 2 ++
.../spark/streaming/ui/StreamingPage.scala | 37 ++++++++++++++++----
2 files changed, 33 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/bd247317/core/src/main/resources/org/apache/spark/ui/static/webui.js
----------------------------------------------------------------------
diff --git a/core/src/main/resources/org/apache/spark/ui/static/webui.js b/core/src/main/resources/org/apache/spark/ui/static/webui.js
index e575c4c..83009df 100644
--- a/core/src/main/resources/org/apache/spark/ui/static/webui.js
+++ b/core/src/main/resources/org/apache/spark/ui/static/webui.js
@@ -80,4 +80,6 @@ $(function() {
collapseTablePageLoad('collapse-aggregated-poolActiveStages','aggregated-poolActiveStages');
collapseTablePageLoad('collapse-aggregated-tasks','aggregated-tasks');
collapseTablePageLoad('collapse-aggregated-rdds','aggregated-rdds');
+ collapseTablePageLoad('collapse-aggregated-activeBatches','aggregated-activeBatches');
+ collapseTablePageLoad('collapse-aggregated-completedBatches','aggregated-completedBatches');
});
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/spark/blob/bd247317/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala
----------------------------------------------------------------------
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala
index 7abafd6..3a176f6 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala
@@ -490,15 +490,40 @@ private[ui] class StreamingPage(parent: StreamingTab)
sortBy(_.batchTime.milliseconds).reverse
val activeBatchesContent = {
- <h4 id="active">Active Batches ({runningBatches.size + waitingBatches.size})</h4> ++
- new ActiveBatchTable(runningBatches, waitingBatches, listener.batchDuration).toNodeSeq
+ <div class="row-fluid">
+ <div class="span12">
+ <span id="activeBatches" class="collapse-aggregated-activeBatches collapse-table"
+ onClick="collapseTable('collapse-aggregated-activeBatches',
+ 'aggregated-activeBatches')">
+ <h4>
+ <span class="collapse-table-arrow arrow-open"></span>
+ <a>Active Batches ({runningBatches.size + waitingBatches.size})</a>
+ </h4>
+ </span>
+ <div class="aggregated-activeBatches collapsible-table">
+ {new ActiveBatchTable(runningBatches, waitingBatches, listener.batchDuration).toNodeSeq}
+ </div>
+ </div>
+ </div>
}
val completedBatchesContent = {
- <h4 id="completed">
- Completed Batches (last {completedBatches.size} out of {listener.numTotalCompletedBatches})
- </h4> ++
- new CompletedBatchTable(completedBatches, listener.batchDuration).toNodeSeq
+ <div class="row-fluid">
+ <div class="span12">
+ <span id="completedBatches" class="collapse-aggregated-completedBatches collapse-table"
+ onClick="collapseTable('collapse-aggregated-completedBatches',
+ 'aggregated-completedBatches')">
+ <h4>
+ <span class="collapse-table-arrow arrow-open"></span>
+ <a>Completed Batches (last {completedBatches.size}
+ out of {listener.numTotalCompletedBatches})</a>
+ </h4>
+ </span>
+ <div class="aggregated-completedBatches collapsible-table">
+ {new CompletedBatchTable(completedBatches, listener.batchDuration).toNodeSeq}
+ </div>
+ </div>
+ </div>
}
activeBatchesContent ++ completedBatchesContent
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org