Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-7485 TestSplitLogManager is still flaky on windows (Enis) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1428168 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
larsh 2013-01-03 05:32:17 +00:00
parent a1079157ec
commit 76cc226867
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestSplitLogManager.java
View File

@ -220,7 +220,7 @@ public class TestSplitLogManager {
slm = new SplitLogManager(zkw, conf, stopper, master, DUMMY_MASTER, null); slm = new SplitLogManager(zkw, conf, stopper, master, DUMMY_MASTER, null);
slm.finishInitialization(); slm.finishInitialization();
waitForCounter(tot_mgr_orphan_task_acquired, 0, 1, 100); waitForCounter(tot_mgr_orphan_task_acquired, 0, 1, to/2);
Task task = slm.findOrCreateOrphanTask(tasknode); Task task = slm.findOrCreateOrphanTask(tasknode);
assertTrue(task.isOrphan()); assertTrue(task.isOrphan());
waitForCounter(tot_mgr_heartbeat, 0, 1, to/2); waitForCounter(tot_mgr_heartbeat, 0, 1, to/2);
@ -508,7 +508,7 @@ public class TestSplitLogManager {
LOG.info("testVanishingTaskZNode"); LOG.info("testVanishingTaskZNode");
conf.setInt("hbase.splitlog.manager.unassigned.timeout", 0); conf.setInt("hbase.splitlog.manager.unassigned.timeout", 0);
conf.setInt("hbase.splitlog.manager.timeoutmonitor.period", 1000);
slm = new SplitLogManager(zkw, conf, stopper, master, DUMMY_MASTER, null); slm = new SplitLogManager(zkw, conf, stopper, master, DUMMY_MASTER, null);
slm.finishInitialization(); slm.finishInitialization();
FileSystem fs = TEST_UTIL.getTestFileSystem(); FileSystem fs = TEST_UTIL.getTestFileSystem();
@ -537,7 +537,7 @@ public class TestSplitLogManager {
// remove the task znode, to finish the distributed log splitting // remove the task znode, to finish the distributed log splitting
ZKUtil.deleteNode(zkw, znode); ZKUtil.deleteNode(zkw, znode);
waitForCounter(tot_mgr_get_data_nonode, 0, 1, 30000); waitForCounter(tot_mgr_get_data_nonode, 0, 1, 30000);
waitForCounter(tot_mgr_log_split_batch_success, 0, 1, 1000); waitForCounter(tot_mgr_log_split_batch_success, 0, 1, to/2);
assertTrue(fs.exists(logFile)); assertTrue(fs.exists(logFile));
} finally { } finally {
if (thread != null) { if (thread != null) {