svn commit: r1004152 - in /incubator/hama/trunk: conf/hama-default.xml src/java/org/apache/hama/bsp/LocalBSPCluster.java

[ed...@apache.org]

Author: edwardyoon
Date: Mon Oct  4 09:08:12 2010
New Revision: 1004152

URL: http://svn.apache.org/viewvc?rev=1004152&view=rev
Log:
bsp.groom.port is unnused and superseeded by bsp.peer.port

Modified:
    incubator/hama/trunk/conf/hama-default.xml
    incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPCluster.java

Modified: incubator/hama/trunk/conf/hama-default.xml
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/conf/hama-default.xml?rev=1004152&r1=1004151&r2=1004152&view=diff
==============================================================================
--- incubator/hama/trunk/conf/hama-default.xml (original)
+++ incubator/hama/trunk/conf/hama-default.xml Mon Oct  4 09:08:12 2010
@@ -36,8 +36,8 @@
     <description>The port master should bind to.</description>
   </property>
   <property>
-    <name>bsp.groom.port</name>
-    <value>40020</value>
+    <name>bsp.peer.port</name>
+     <value>61000</value>
     <description>The port an groom server binds to.</description>
   </property>
   <property>

Modified: incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPCluster.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPCluster.java?rev=1004152&r1=1004151&r2=1004152&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPCluster.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPCluster.java Mon Oct  4 09:08:12 2010
@@ -36,7 +36,7 @@ public class LocalBSPCluster {
       final Class<? extends BSPMaster> masterClass,
       final Class<? extends GroomServer> groomServerClass) throws IOException, InterruptedException {
     conf.set("bsp.master.port", "40000");
-    conf.set("bsp.groom.port", "40020");
+    conf.set("bsp.peer.port", "61000");
     conf.set("bsp.local.dir", conf.get("hadoop.tmp.dir") + "/bsp/local");
     conf.set("bsp.system.dir", conf.get("hadoop.tmp.dir") + "/bsp/system");
     this.conf = conf;