Added logInfo

liancheng · May 12, 2015 · 99c7678 · 99c7678
1 parent 65aec20
commit 99c7678
Showing 1 changed file with 1 addition and 0 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
@@ -542,6 +542,7 @@ class StreamingContext private[streaming] (
           state = StreamingContextState.ACTIVE
           setActiveContext(this)
         }
+        logInfo("StreamingContext started")
       case ACTIVE =>
         logWarning("StreamingContext has already been started")
       case STOPPED =>