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

HBASE-10059: TestSplitLogWorker#testMultipleTasks fails occasionally 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1549738 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
jeffreyz 2013-12-10 01:55:28 +00:00
parent 0b737248c3
commit 163075379c
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitLogWorker.java
View File

@ -235,7 +235,7 @@ public class TestSplitLogWorker {
assertTrue(slt.isOwned(SRV));
slt = new SplitLogTask.Unassigned(MANAGER);
ZKUtil.setData(zkw, PATH, slt.toByteArray());
waitForCounter(SplitLogCounters.tot_wkr_preempt_task, 0, 1, 1500);
waitForCounter(SplitLogCounters.tot_wkr_preempt_task, 0, 1, 5000);
} finally {
stopSplitLogWorker(slw);
}
@ -254,13 +254,13 @@ public class TestSplitLogWorker {
try {
Thread.yield(); // let the worker start
Thread.sleep(100);
waitForCounter(SplitLogCounters.tot_wkr_task_grabing, 0, 1, 1500);
waitForCounter(SplitLogCounters.tot_wkr_task_grabing, 0, 1, 5000);
SplitLogTask unassignedManager = new SplitLogTask.Unassigned(MANAGER);
zkw.getRecoverableZooKeeper().create(PATH1, unassignedManager.toByteArray(),
Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
waitForCounter(SplitLogCounters.tot_wkr_task_acquired, 0, 1, 1500);
waitForCounter(SplitLogCounters.tot_wkr_task_acquired, 0, 1, 5000);
// now the worker is busy doing the above task
// create another task
@ -272,9 +272,9 @@ public class TestSplitLogWorker {
final ServerName anotherWorker = ServerName.valueOf("another-worker,1,1");
SplitLogTask slt = new SplitLogTask.Owned(anotherWorker);
ZKUtil.setData(zkw, PATH1, slt.toByteArray());
waitForCounter(SplitLogCounters.tot_wkr_preempt_task, 0, 1, 1500);
waitForCounter(SplitLogCounters.tot_wkr_preempt_task, 0, 1, 5000);
waitForCounter(SplitLogCounters.tot_wkr_task_acquired, 1, 2, 1500);
waitForCounter(SplitLogCounters.tot_wkr_task_acquired, 1, 2, 5000);
assertEquals(2, slw.taskReadySeq);
byte [] bytes = ZKUtil.getData(zkw, PATH2);
slt = SplitLogTask.parseFrom(bytes);