Added synchronized

tdas · tdas · commit 3da6547d68b1 · 2015-05-11T16:45:38.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
@@ -521,7 +521,7 @@ class StreamingContext private[streaming] (
    * - StreamingContextState.STOPPED - The context has been stopped and cannot be used any more.
    */
   @DeveloperApi
-  def getState(): StreamingContextState = {
+  def getState(): StreamingContextState = synchronized {
     state
   }
 

Original file line number	Diff line number	Diff line change
`@@ -521,7 +521,7 @@ class StreamingContext private[streaming] (`
`521`	`521`	`* - StreamingContextState.STOPPED - The context has been stopped and cannot be used any more.`
`522`	`522`	`*/`
`523`	`523`	`@DeveloperApi`
`524`		`- def getState(): StreamingContextState = {`
	`524`	`+ def getState(): StreamingContextState = synchronized {`
`525`	`525`	`state`
`526`	`526`	`}`
`527`	`527`