From 9d2d53349353267db80cd4bce6db059736237575 Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@cs.berkeley.edu>
Date: Thu, 21 Apr 2011 17:40:26 -0700
Subject: [PATCH] Temporary fix for issue #42.
---
core/src/main/scala/spark/BitTorrentBroadcast.scala | 3 +++
core/src/main/scala/spark/ChainedBroadcast.scala | 3 +++
2 files changed, 6 insertions(+)
diff --git a/core/src/main/scala/spark/BitTorrentBroadcast.scala b/core/src/main/scala/spark/BitTorrentBroadcast.scala
index 96d3643ffd..e9339290cb 100644
--- a/core/src/main/scala/spark/BitTorrentBroadcast.scala
+++ b/core/src/main/scala/spark/BitTorrentBroadcast.scala
@@ -1079,6 +1079,9 @@ extends Logging {
def initialize (isMaster__ : Boolean): Unit = {
synchronized {
if (!initialized) {
+ // Fix for issue #42
+ MasterHostAddress_ =
+ System.getProperty ("spark.broadcast.masterHostAddress", "")
MasterTrackerPort_ =
System.getProperty ("spark.broadcast.masterTrackerPort", "11111").toInt
BlockSize_ =
diff --git a/core/src/main/scala/spark/ChainedBroadcast.scala b/core/src/main/scala/spark/ChainedBroadcast.scala
index afd3c0293c..d13553afde 100644
--- a/core/src/main/scala/spark/ChainedBroadcast.scala
+++ b/core/src/main/scala/spark/ChainedBroadcast.scala
@@ -745,6 +745,9 @@ extends Logging {
def initialize (isMaster__ : Boolean): Unit = {
synchronized {
if (!initialized) {
+ // Fix for issue #42
+ MasterHostAddress_ =
+ System.getProperty ("spark.broadcast.masterHostAddress", "")
MasterTrackerPort_ =
System.getProperty ("spark.broadcast.masterTrackerPort", "22222").toInt
BlockSize_ =
--
GitLab