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

Temporary fix for issue #42.

Browse source
This commit is contained in:
Mosharaf Chowdhury 2011-04-21 17:40:26 -07:00
parent 5c9535228a
commit 9d2d533493
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
core/src/main/scala/spark/BitTorrentBroadcast.scala
View file

@ -1079,6 +1079,9 @@ extends Logging {
def initialize (isMaster__ : Boolean): Unit = { def initialize (isMaster__ : Boolean): Unit = {
synchronized { synchronized {
if (!initialized) { if (!initialized) {
// Fix for issue #42
MasterHostAddress_ =
System.getProperty ("spark.broadcast.masterHostAddress", "")
MasterTrackerPort_ = MasterTrackerPort_ =
System.getProperty ("spark.broadcast.masterTrackerPort", "11111").toInt System.getProperty ("spark.broadcast.masterTrackerPort", "11111").toInt
BlockSize_ = BlockSize_ =

3
core/src/main/scala/spark/ChainedBroadcast.scala
View file

@ -745,6 +745,9 @@ extends Logging {
def initialize (isMaster__ : Boolean): Unit = { def initialize (isMaster__ : Boolean): Unit = {
synchronized { synchronized {
if (!initialized) { if (!initialized) {
// Fix for issue #42
MasterHostAddress_ =
System.getProperty ("spark.broadcast.masterHostAddress", "")
MasterTrackerPort_ = MasterTrackerPort_ =
System.getProperty ("spark.broadcast.masterTrackerPort", "22222").toInt System.getProperty ("spark.broadcast.masterTrackerPort", "22222").toInt
BlockSize_ = BlockSize_ =