[SPARK-7350] [STREAMING] [WEBUI] Attach the Streaming tab when callin…

…g 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 <[email protected]> Closes apache#5898 from zsxwing/SPARK-7350 and squashes the following commits: e676487 [zsxwing] Attach the Streaming tab when calling ssc.start()
jeanlyn · May 28, 2015 · 920df68 · 920df68
1 parent f5e304c
commit 920df68
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git 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
@@ -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)