diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitLogManager.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitLogManager.java index e5781fe7597..f6a79535776 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitLogManager.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitLogManager.java @@ -590,12 +590,16 @@ public class TestSplitLogManager { for (Map.Entry entry : slm.getTasks().entrySet()) { final ServerName worker1 = ServerName.valueOf("worker1,1,1"); SplitLogTask slt = new SplitLogTask.Done(worker1, RecoveryMode.LOG_SPLITTING); + boolean encounteredZKException = false; try { ZKUtil.setData(zkw, entry.getKey(), slt.toByteArray()); } catch (KeeperException e) { LOG.warn(e); + encounteredZKException = true; + } + if (!encounteredZKException) { + done = true; } - done = true; } } };