Index: src/test/java/org/apache/hadoop/hbase/zookeeper/TestHQuorumPeer.java =================================================================== --- src/test/java/org/apache/hadoop/hbase/zookeeper/TestHQuorumPeer.java (revision 1034563) +++ src/test/java/org/apache/hadoop/hbase/zookeeper/TestHQuorumPeer.java (working copy) @@ -91,7 +91,11 @@ String s = "dataDir=" + this.dataDir.toString() + "\n" + "clientPort=2181\n" + - "server.0=${hbase.master.hostname}:2888:3888\n"; + "initLimit=2\n" + + "syncLimit=2\n" + + "server.0=${hbase.master.hostname}:2888:3888\n" + + "server.1=server1:2888:3888\n" + + "server.2=server2:2888:3888\n"; System.setProperty("hbase.master.hostname", "localhost"); InputStream is = new ByteArrayInputStream(s.getBytes()); @@ -103,13 +107,14 @@ Integer.valueOf(properties.getProperty("clientPort"))); assertEquals("localhost:2888:3888", properties.get("server.0")); + HQuorumPeer.writeMyID(properties); QuorumPeerConfig config = new QuorumPeerConfig(); config.parseProperties(properties); assertEquals(this.dataDir.toString(), config.getDataDir()); assertEquals(2181, config.getClientPortAddress().getPort()); Map servers = config.getServers(); - assertEquals(1, servers.size()); + assertEquals(3, servers.size()); assertTrue(servers.containsKey(Long.valueOf(0))); QuorumServer server = servers.get(Long.valueOf(0)); assertEquals("localhost", server.addr.getHostName()); Index: src/main/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java (revision 1034563) +++ src/main/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java (working copy) @@ -83,7 +83,7 @@ return address.equals("localhost") || address.equals("127.0.0.1"); } - private static void writeMyID(Properties properties) throws IOException { + static void writeMyID(Properties properties) throws IOException { long myId = -1; Configuration conf = HBaseConfiguration.create();