You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2016/03/16 16:04:19 UTC
hbase git commit: HBASE-15360 Fix flaky TestSimpleRpcScheduler (Duo
Zhang)
Repository: hbase
Updated Branches:
refs/heads/master f120602f1 -> 9eb25bd5c
HBASE-15360 Fix flaky TestSimpleRpcScheduler (Duo Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9eb25bd5
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9eb25bd5
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9eb25bd5
Branch: refs/heads/master
Commit: 9eb25bd5c92619257a3ffb3bbbb090a712cf226a
Parents: f120602
Author: stack <st...@apache.org>
Authored: Wed Mar 16 08:04:10 2016 -0700
Committer: stack <st...@apache.org>
Committed: Wed Mar 16 08:04:10 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/9eb25bd5/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java
index 916037b..6454537 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java
@@ -354,7 +354,9 @@ public class TestSimpleRpcScheduler {
schedConf.setInt("hbase.ipc.server.max.callqueue.length", 0);
scheduler.onConfigurationChange(schedConf);
assertFalse(scheduler.dispatch(putCallTask));
-
+ while (scheduler.getGeneralQueueLength() > 0) {
+ Threads.sleepWithoutInterrupt(100);
+ }
schedConf.setInt("hbase.ipc.server.max.callqueue.length", 1);
scheduler.onConfigurationChange(schedConf);
assertTrue(scheduler.dispatch(putCallTask));