diff options
| -rw-r--r-- | conf/java-opts | 2 | ||||
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/conf/java-opts b/conf/java-opts index 0307361a26..e8b1255f82 100644 --- a/conf/java-opts +++ b/conf/java-opts @@ -1 +1 @@ --Dspark.broadcast.masterHostAddress=127.0.0.1 -Dspark.broadcast.masterTrackerPort=11111 -Dspark.broadcast.blockSize=256 -Dspark.broadcast.maxRetryCount=2 -Dspark.broadcast.TrackerSocketTimeout=50000 -Dspark.broadcast.ServerSocketTimeout=10000 -Dspark.broadcast.dualMode=false +-Dspark.broadcast.MasterHostAddress=127.0.0.1 -Dspark.broadcast.MasterTrackerPort=22222 -Dspark.broadcast.BlockSize=256 -Dspark.broadcast.MaxRetryCount=2 -Dspark.broadcast.TrackerSocketTimeout=50000 -Dspark.broadcast.ServerSocketTimeout=10000 -Dspark.broadcast.DualMode=false diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index fc83803350..a9a1e98e2b 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -951,7 +951,7 @@ extends Logging { private var isMaster_ = false private var MasterHostAddress_ = "127.0.0.1" - private var MasterTrackerPort_ : Int = 11111 + private var MasterTrackerPort_ : Int = 22222 private var BlockSize_ : Int = 512 * 1024 private var MaxRetryCount_ : Int = 2 @@ -976,7 +976,7 @@ extends Logging { MasterHostAddress_ = System.getProperty ("spark.broadcast.MasterHostAddress", "127.0.0.1") MasterTrackerPort_ = - System.getProperty ("spark.broadcast.MasterTrackerPort", "11111").toInt + System.getProperty ("spark.broadcast.MasterTrackerPort", "22222").toInt BlockSize_ = System.getProperty ("spark.broadcast.BlockSize", "512").toInt * 1024 MaxRetryCount_ = |