ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[HOTFIX] Mark lastSetSparkEnv @volatile in case it gets HotSpot-cached

Browse source 
On branch adatao-global-SparkEnv
Changes to be committed:

	modified:   core/src/main/scala/spark/SparkEnv.scala
This commit is contained in:
Christopher Nguyen 2013-08-05 17:22:27 -07:00
parent 39e4fda76f
commit b1bbbe699c
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/src/main/scala/spark/SparkEnv.scala
View file

@ -97,7 +97,7 @@ class SparkEnv (
object SparkEnv extends Logging {
private val env = new ThreadLocal[SparkEnv]
private var lastSetSparkEnv : SparkEnv = _
@volatile private var lastSetSparkEnv : SparkEnv = _
def set(e: SparkEnv) {
lastSetSparkEnv = e