diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-08 18:32:17 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-08 18:32:17 -0800 |
| commit | 1820634dbffab5bf2c9af43d4eba6db8fcb0ba06 (patch) | |
| tree | 6a4108a1ba325dec5e5f7cfbc4378b67630f6f08 | |
| parent | 49a2db09fb4b8cf2b2f207ad90a6c492f6952e87 (diff) | |
| download | spark-1820634dbffab5bf2c9af43d4eba6db8fcb0ba06.tar.gz spark-1820634dbffab5bf2c9af43d4eba6db8fcb0ba06.tar.bz2 spark-1820634dbffab5bf2c9af43d4eba6db8fcb0ba06.zip | |
Bug fix: java-opts had wrong (non-capitalized) variable names.
| -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_ = |