Fixed bug again

liancheng · May 12, 2015 · 7dadfc3 · 7dadfc3
1 parent 99c7678
commit 7dadfc3
Showing 1 changed file with 3 additions and 4 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
@@ -531,16 +531,15 @@ class StreamingContext private[streaming] (
   def start(): Unit = synchronized {
     state match {
       case INITIALIZED =>
-        import StreamingContext._
         validate()
         startSite.set(DStream.getCreationSite())
         sparkContext.setCallSite(startSite.get)
-        ACTIVATION_LOCK.synchronized {
-          assertNoOtherContextIsActive()
+        StreamingContext.ACTIVATION_LOCK.synchronized {
+          StreamingContext.assertNoOtherContextIsActive()
           scheduler.start()
           uiTab.foreach(_.attach())
           state = StreamingContextState.ACTIVE
-          setActiveContext(this)
+          StreamingContext.setActiveContext(this)
         }
         logInfo("StreamingContext started")
       case ACTIVE =>