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

Fixed some configuration bugs

Browse source
This commit is contained in:
Mosharaf Chowdhury 2010-10-27 16:18:26 -07:00
parent e4dc7847ba
commit ae2c93a54b
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
conf/java-opts
View file

@ -1 +1 @@
-Dspark.broadcast.MasterHostAddress=127.0.0.1 -Dspark.broadcast.MasterTrackerPort=11111 -Dspark.broadcast.BlockSize=256 -Dspark.broadcast.MaxRetryCount=2 -Dspark.broadcast.ServerSocketTimout=50000
-Dspark.broadcast.MasterHostAddress=127.0.0.1 -Dspark.broadcast.MasterTrackerPort=11111 -Dspark.broadcast.BlockSize=256 -Dspark.broadcast.MaxRetryCount=2 -Dspark.broadcast.ServerSocketTimout=50000 -Dspark.broadcast.MaxChatTime=500

6
src/scala/spark/Broadcast.scala
View file

@ -1017,7 +1017,7 @@ extends Logging {
System.getProperty ("spark.broadcast.ServerSocketTimout", "50000").toInt
MinKnockInterval_ =
System.getProperty ("spark.broadcast.MinKnockInterval", "100").toInt
System.getProperty ("spark.broadcast.MinKnockInterval", "500").toInt
MaxKnockInterval_ =
System.getProperty ("spark.broadcast.MaxKnockInterval", "999").toInt
@ -1030,9 +1030,9 @@ extends Logging {
System.getProperty ("spark.broadcast.MaxTxPeers", "4").toInt
MaxChatTime_ =
System.getProperty ("spark.broadcast.MaxChatTime", "4").toInt
System.getProperty ("spark.broadcast.MaxChatTime", "250").toInt
MaxChatBlocks_ =
System.getProperty ("spark.broadcast.MaxChatBlocks", "4").toInt
System.getProperty ("spark.broadcast.MaxChatBlocks", "1024").toInt
isMaster_ = isMaster__