diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-05-05 15:09:58 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-05-05 15:10:27 +0100 |
| commit | 49923f7ca92fcdeec3aae501822f5db380acf9cb (patch) | |
| tree | 74069fea6faf3821fdec1de5eb7a50b861ff013a /streaming/src | |
| parent | 6f35dac50067e2ab3cf59202c7b3f46ad23a108b (diff) | |
| download | spark-49923f7ca92fcdeec3aae501822f5db380acf9cb.tar.gz spark-49923f7ca92fcdeec3aae501822f5db380acf9cb.tar.bz2 spark-49923f7ca92fcdeec3aae501822f5db380acf9cb.zip | |
[SPARK-7350] [STREAMING] [WEBUI] Attach the Streaming tab when calling ssc.start()
It's meaningless to display the Streaming tab before `ssc.start()`. So we should attach it in the `ssc.start` method.
Author: zsxwing <zsxwing@gmail.com>
Closes #5898 from zsxwing/SPARK-7350 and squashes the following commits:
e676487 [zsxwing] Attach the Streaming tab when calling ssc.start()
(cherry picked from commit c6d1efba29a4235130024fee9f118e6b2cb89ce1)
Signed-off-by: Sean Owen <sowen@cloudera.com>
Diffstat (limited to 'streaming/src')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala | 1 | ||||
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingTab.scala | 5 |
2 files changed, 5 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala index 117cb59fb6..b1ad0d42ec 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala @@ -527,6 +527,7 @@ class StreamingContext private[streaming] ( validate() sparkContext.setCallSite(DStream.getCreationSite()) scheduler.start() + uiTab.foreach(_.attach()) state = Started } diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingTab.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingTab.scala index e4039639ad..f307b54bb9 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingTab.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingTab.scala @@ -37,7 +37,10 @@ private[spark] class StreamingTab(val ssc: StreamingContext) ssc.sc.addSparkListener(listener) attachPage(new StreamingPage(this)) attachPage(new BatchPage(this)) - parent.attachTab(this) + + def attach() { + getSparkUI(ssc).attachTab(this) + } def detach() { getSparkUI(ssc).detachTab(this) |