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

HBASE-10274 MiniZookeeperCluster should close ZKDatabase when shutdown ZooKeeperServers (chendihao via enis) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1557919 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Enis Soztutar 2014-01-14 03:29:20 +00:00
parent 00ad1cf236
commit 185aec9c24
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java
View File

@ -270,6 +270,8 @@ public class MiniZooKeeperCluster {
throw new IOException("Waiting for shutdown of standalone server"); throw new IOException("Waiting for shutdown of standalone server");
} }
zooKeeperServers.get(activeZKServerIndex).getZKDatabase().close();
// remove the current active zk server // remove the current active zk server
standaloneServerFactoryList.remove(activeZKServerIndex); standaloneServerFactoryList.remove(activeZKServerIndex);
clientPortList.remove(activeZKServerIndex); clientPortList.remove(activeZKServerIndex);
@ -311,6 +313,8 @@ public class MiniZooKeeperCluster {
throw new IOException("Waiting for shutdown of standalone server"); throw new IOException("Waiting for shutdown of standalone server");
} }
zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();
// remove this backup zk server // remove this backup zk server
standaloneServerFactoryList.remove(backupZKServerIndex); standaloneServerFactoryList.remove(backupZKServerIndex);
clientPortList.remove(backupZKServerIndex); clientPortList.remove(backupZKServerIndex);