private void checkAndFixTableLocks() throws IOException { ZooKeeperWatcher zkw = createZooKeeperWatcher(); try { TableLockChecker checker = new TableLockChecker(zkw, errors); checker.checkTableLocks(); if (this.fixTableLocks) { checker.fixExpiredTableLocks(); } } finally { zkw.close(); } }
private void checkAndFixTableLocks() throws IOException { TableLockChecker checker = new TableLockChecker(createZooKeeperWatcher(), errors); checker.checkTableLocks(); if (this.fixTableLocks) { checker.fixExpiredTableLocks(); } }