diff --git a/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java b/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java index 096b1334734..54b6d4573ce 100644 --- a/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java +++ b/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java @@ -384,6 +384,7 @@ public class SplitLogManager extends ZooKeeperListener { setDone(path, true); return; } + data = this.watcher.getRecoverableZooKeeper().removeMetaData(data); // LOG.debug("set watch on " + path + " got data " + new String(data)); if (TaskState.TASK_UNASSIGNED.equals(data)) { LOG.debug("task not yet acquired " + path + " ver = " + version);