You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2010/10/12 04:55:08 UTC

svn commit: r1021600 - in /incubator/hama/trunk/src: java/org/apache/hama/zookeeper/QuorumPeer.java test/org/apache/hama/HamaClusterTestCase.java

Author: edwardyoon
Date: Tue Oct 12 02:55:08 2010
New Revision: 1021600

URL: http://svn.apache.org/viewvc?rev=1021600&view=rev
Log:
Trivial changes: I just edited some comments.

Modified:
    incubator/hama/trunk/src/java/org/apache/hama/zookeeper/QuorumPeer.java
    incubator/hama/trunk/src/test/org/apache/hama/HamaClusterTestCase.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/zookeeper/QuorumPeer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/zookeeper/QuorumPeer.java?rev=1021600&r1=1021599&r2=1021600&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/zookeeper/QuorumPeer.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/zookeeper/QuorumPeer.java Tue Oct 12 02:55:08 2010
@@ -153,7 +153,7 @@ public class QuorumPeer implements Const
   /**
    * Make a Properties object holding ZooKeeper config equivalent to zoo.cfg.
    * If there is a zoo.cfg in the classpath, simply read it in. Otherwise parse
-   * the corresponding config options from the HBase XML configs and generate
+   * the corresponding config options from the Hama XML configs and generate
    * the appropriate ZooKeeper properties.
    * @param conf Configuration to read from.
    * @return Properties holding mappings representing ZooKeeper zoo.cfg file.
@@ -172,10 +172,10 @@ public class QuorumPeer implements Const
       }
     }
 
-    // Otherwise, use the configuration options from HBase's XML files.
+    // Otherwise, use the configuration options from Hama's XML files.
     Properties zkProperties = new Properties();
 
-    // Directly map all of the hbase.zookeeper.property.KEY properties.
+    // Directly map all of the hama.zookeeper.property.KEY properties.
     for (Entry<String, String> entry : conf) {
       String key = entry.getKey();
       if (key.startsWith(ZK_CFG_PROPERTY)) {
@@ -210,9 +210,9 @@ public class QuorumPeer implements Const
   }
 
   /**
-   * Parse ZooKeeper's zoo.cfg, injecting HBase Configuration variables in.
+   * Parse ZooKeeper's zoo.cfg, injecting Hama Configuration variables in.
    * This method is used for testing so we can pass our own InputStream.
-   * @param conf HBaseConfiguration to use for injecting variables.
+   * @param conf Configuration to use for injecting variables.
    * @param inputStream InputStream to read from.
    * @return Properties parsed from config stream with variables substituted.
    * @throws IOException if anything goes wrong parsing config
@@ -248,7 +248,7 @@ public class QuorumPeer implements Const
         }
         if (substituteValue == null) {
           String msg = "variable " + variable + " not set in system property "
-                     + "or hbase configs";
+                     + "or hama configs";
           LOG.fatal(msg);
           throw new IOException(msg);
         }
@@ -258,7 +258,7 @@ public class QuorumPeer implements Const
         varEnd += VARIABLE_END_LENGTH;
         varStart = value.indexOf(VARIABLE_START, varEnd);
       }
-      // Special case for 'hbase.cluster.distributed' property being 'true'
+      // Special case for 'hama.cluster.distributed' property being 'true'
       if (key.startsWith("server.")) {
         if (conf.get(CLUSTER_DISTRIBUTED).equals(CLUSTER_IS_DISTRIBUTED) &&
             value.startsWith("localhost")) {

Modified: incubator/hama/trunk/src/test/org/apache/hama/HamaClusterTestCase.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/test/org/apache/hama/HamaClusterTestCase.java?rev=1021600&r1=1021599&r2=1021600&view=diff
==============================================================================
--- incubator/hama/trunk/src/test/org/apache/hama/HamaClusterTestCase.java (original)
+++ incubator/hama/trunk/src/test/org/apache/hama/HamaClusterTestCase.java Tue Oct 12 02:55:08 2010
@@ -44,7 +44,7 @@ public abstract class HamaClusterTestCas
     // need to edit the config to add the ZooKeeper servers.
     this.zooKeeperCluster = new MiniZooKeeperCluster();
     int clientPort = this.zooKeeperCluster.startup(testDir);
-    conf.set("hbase.zookeeper.property.clientPort", Integer.toString(clientPort));
+    conf.set("hama.zookeeper.property.clientPort", Integer.toString(clientPort));
 
     // start the mini cluster
     this.cluster = new MiniBSPCluster(conf, groomServers);