From ae2c93a54b20ed2ababcfba095be84077fa78cfe Mon Sep 17 00:00:00 2001 From: Mosharaf Chowdhury Date: Wed, 27 Oct 2010 16:18:26 -0700 Subject: [PATCH] Fixed some configuration bugs --- conf/java-opts | 2 +- src/scala/spark/Broadcast.scala | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/conf/java-opts b/conf/java-opts index f279d27806..39bdbb77bb 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.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 diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 94d0fed8b0..60ac13fa5e 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -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__