Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Temporary fix for issue #42.

  • Loading branch information...
commit 9d2d53349353267db80cd4bce6db059736237575 1 parent 5c95352
@mosharaf mosharaf authored
View
3  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_ =
View
3  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_ =
Please sign in to comment.
Something went wrong with that request. Please try again.