From d16c9d37762014270b4f7e0b3b0c721f82e3bfb5 Mon Sep 17 00:00:00 2001 From: Jimmy Xiang Date: Mon, 1 Sep 2014 14:27:06 -0700 Subject: [PATCH] HBASE-11867 TestSplitLogManager.testUnassignedTimeout is flaky --- .../org/apache/hadoop/hbase/master/TestSplitLogManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 125cacda13e..2aa443417a1 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 @@ -206,7 +206,7 @@ public class TestSplitLogManager { conf.setInt("hbase.splitlog.manager.unassigned.timeout", 2 * to); conf.setInt("hbase.splitlog.manager.timeoutmonitor.period", 100); - to = to + 4 * 100; + to = to + 16 * 100; this.mode = (conf.getBoolean(HConstants.DISTRIBUTED_LOG_REPLAY_KEY, false) ? RecoveryMode.LOG_REPLAY @@ -455,7 +455,7 @@ public class TestSplitLogManager { SplitLogTask slt = new SplitLogTask.Resigned(worker1, this.mode); assertEquals(tot_mgr_resubmit.get(), 0); ZKUtil.setData(zkw, tasknode, slt.toByteArray()); - int version = ZKUtil.checkExists(zkw, tasknode); + ZKUtil.checkExists(zkw, tasknode); // Could be small race here. if (tot_mgr_resubmit.get() == 0) { waitForCounter(tot_mgr_resubmit, 0, 1, to/2);