From 1013a01469d08eaeb42e58e4bc442042387796fc Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>
Date: Thu, 2 Dec 2010 02:36:21 -0800
Subject: Made the root Broadcast object initilization method 'synchronized'.

---
 src/scala/spark/Broadcast.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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")
-- 
cgit v1.2.3