diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-12-02 02:36:21 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-12-02 02:36:21 -0800 |
| commit | 1013a01469d08eaeb42e58e4bc442042387796fc (patch) | |
| tree | 5adad374b911f5a19fea6a881c1a6a9bf83944f0 | |
| parent | a69638d98da27151086f85b2e0476ee4c2f92b4b (diff) | |
| download | spark-1013a01469d08eaeb42e58e4bc442042387796fc.tar.gz spark-1013a01469d08eaeb42e58e4bc442042387796fc.tar.bz2 spark-1013a01469d08eaeb42e58e4bc442042387796fc.zip | |
Made the root Broadcast object initilization method 'synchronized'.
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 5b7942834f..f59912b4c8 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -28,7 +28,7 @@ extends Logging { private var broadcastFactory: BroadcastFactory = null // Called by SparkContext or Executor before using Broadcast - def initialize (isMaster: Boolean): Unit = { + def initialize (isMaster: Boolean): Unit = synchronized { if (!initialized) { val broadcastFactoryClass = System.getProperty("spark.broadcast.Factory", "spark.BitTorrentBroadcastFactory") |