hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject hbase git commit: HBASE-15360 Fix flaky TestSimpleRpcScheduler (Duo Zhang)
Date Wed, 16 Mar 2016 15:04:44 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 a00ed93fa -> 3f9ce9785


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/3f9ce978
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3f9ce978
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3f9ce978

Branch: refs/heads/branch-1
Commit: 3f9ce9785a647ff2a9e64baad1e0398ace59060d
Parents: a00ed93
Author: stack <stack@apache.org>
Authored: Wed Mar 16 08:04:10 2016 -0700
Committer: stack <stack@apache.org>
Committed: Wed Mar 16 08:04:37 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/3f9ce978/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 dd3433c..1229ea2 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
@@ -348,7 +348,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));


Mime
View raw message