diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java index 36dd2d6..149c8de 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java @@ -3345,7 +3345,11 @@ public class HBaseFsck extends Configured implements Closeable { KeeperException { undeployRegions(hi); ZooKeeperWatcher zkw = createZooKeeperWatcher(); - ZKUtil.deleteNode(zkw, zkw.getZNodeForReplica(hi.metaEntry.getReplicaId())); + try { + ZKUtil.deleteNode(zkw, zkw.getZNodeForReplica(hi.metaEntry.getReplicaId())); + } finally { + zkw.close(); + } } private void assignMetaReplica(int replicaId)