Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-1241 HBase additions to ZooKeeper part 1 (Nitay Joffe via JD)

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@750751 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2009-03-06 02:20:55 +00:00
parent 19491b5a20
commit 7dd31ec417
4 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -72,6 +72,7 @@ Release 0.20.0 - Unreleased
HBASE-1188 Memory size of Java Objects - Make cacheable objects implement HBASE-1188 Memory size of Java Objects - Make cacheable objects implement
HeapSize (Erik Holstad via Stack) HeapSize (Erik Holstad via Stack)
HBASE-1230 Document installation of HBase on Windows HBASE-1230 Document installation of HBase on Windows
HBASE-1241 HBase additions to ZooKeeper part 1 (Nitay Joffe via JD)
Release 0.19.0 - 01/21/2009 Release 0.19.0 - 01/21/2009
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

BIN
lib/zookeeper-3.0.1.jar
View File

Binary file not shown.

BIN
lib/zookeeper-3.1.0-hbase-1241.jar Normal file
View File

Binary file not shown.

7
src/test/org/apache/hadoop/hbase/MiniZooKeeperCluster.java
View File

@ -115,8 +115,6 @@ public class MiniZooKeeperCluster {
} }
private void startupStandalone() throws IOException, InterruptedException { private void startupStandalone() throws IOException, InterruptedException {
ServerStats.registerAsConcrete();
File dir = new File(baseDir, "zookeeper-standalone"); File dir = new File(baseDir, "zookeeper-standalone");
recreateDir(dir); recreateDir(dir);
@ -133,8 +131,6 @@ public class MiniZooKeeperCluster {
// XXX: From o.a.zk.t.QuorumTest.startServers // XXX: From o.a.zk.t.QuorumTest.startServers
private void startupDistributed() throws IOException { private void startupDistributed() throws IOException {
QuorumStats.registerAsConcrete();
// Create map of peers // Create map of peers
HashMap<Long, QuorumServer> peers = new HashMap<Long, QuorumServer>(); HashMap<Long, QuorumServer> peers = new HashMap<Long, QuorumServer>();
for (int id = 1; id <= numPeers; ++id) { for (int id = 1; id <= numPeers; ++id) {
@ -228,8 +224,6 @@ public class MiniZooKeeperCluster {
throw new IOException("Waiting for shutdown of peer " + id); throw new IOException("Waiting for shutdown of peer " + id);
} }
} }
ServerStats.unregister();
} }
private void shutdownStandalone() throws IOException { private void shutdownStandalone() throws IOException {
@ -237,7 +231,6 @@ public class MiniZooKeeperCluster {
if (!waitForServerDown(CLIENT_PORT_START, CONNECTION_TIMEOUT)) { if (!waitForServerDown(CLIENT_PORT_START, CONNECTION_TIMEOUT)) {
throw new IOException("Waiting for shutdown of standalone server"); throw new IOException("Waiting for shutdown of standalone server");
} }
ServerStats.unregister();
} }
// XXX: From o.a.zk.t.ClientBase // XXX: From o.a.zk.t.ClientBase