HBASE-15360 Fix flaky TestSimpleRpcScheduler (Duo Zhang)
This commit is contained in:
parent
a00ed93fae
commit
3f9ce9785a
|
@ -348,7 +348,9 @@ public class TestSimpleRpcScheduler {
|
||||||
schedConf.setInt("hbase.ipc.server.max.callqueue.length", 0);
|
schedConf.setInt("hbase.ipc.server.max.callqueue.length", 0);
|
||||||
scheduler.onConfigurationChange(schedConf);
|
scheduler.onConfigurationChange(schedConf);
|
||||||
assertFalse(scheduler.dispatch(putCallTask));
|
assertFalse(scheduler.dispatch(putCallTask));
|
||||||
|
while (scheduler.getGeneralQueueLength() > 0) {
|
||||||
|
Threads.sleepWithoutInterrupt(100);
|
||||||
|
}
|
||||||
schedConf.setInt("hbase.ipc.server.max.callqueue.length", 1);
|
schedConf.setInt("hbase.ipc.server.max.callqueue.length", 1);
|
||||||
scheduler.onConfigurationChange(schedConf);
|
scheduler.onConfigurationChange(schedConf);
|
||||||
assertTrue(scheduler.dispatch(putCallTask));
|
assertTrue(scheduler.dispatch(putCallTask));
|
||||||
|
|
Loading…
Reference in New Issue