[hbase] branch branch-1.3 updated: HBASE-21766 TestSimpleRpcScheduler is flaky (branch-1)

[apurtell]

This is an automated email from the ASF dual-hosted git repository.

apurtell pushed a commit to branch branch-1.3
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-1.3 by this push:
     new e29b709  HBASE-21766 TestSimpleRpcScheduler is flaky (branch-1)
e29b709 is described below

commit e29b7093023532b89d4f5a99c1ebb11bb1a28759
Author: Andrew Purtell <apurt...@apache.org>
AuthorDate: Wed Jan 23 14:55:04 2019 -0800

    HBASE-21766 TestSimpleRpcScheduler is flaky (branch-1)
---
 .../test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 44059ab..60e2e2c 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
@@ -40,7 +40,6 @@ import java.util.Set;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.ThreadLocalRandom;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -375,6 +374,7 @@ public class TestSimpleRpcScheduler {
       when(putCall.getHeader()).thenReturn(putHead);
 
       assertTrue(scheduler.dispatch(putCallTask));
+      waitUntilQueueEmpty(scheduler);
 
       schedConf.setInt("hbase.ipc.server.max.callqueue.length", 0);
       scheduler.onConfigurationChange(schedConf);