You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by op...@apache.org on 2019/03/06 02:40:55 UTC
[hbase] 02/17: HBASE-21952 Fix unit test:
TestClientOperationInterrupt#testInterrupt50Percent
This is an automated email from the ASF dual-hosted git repository.
openinx pushed a commit to branch HBASE-21879
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 39ef8134fff42d53dcfc11add6f47fafcdb8137f
Author: Xu cang <xu...@apache.org>
AuthorDate: Wed Feb 27 13:19:13 2019 -0800
HBASE-21952 Fix unit test: TestClientOperationInterrupt#testInterrupt50Percent
---
.../apache/hadoop/hbase/client/TestClientOperationInterrupt.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestClientOperationInterrupt.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestClientOperationInterrupt.java
index bc9b715..73ffc00 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestClientOperationInterrupt.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestClientOperationInterrupt.java
@@ -138,8 +138,12 @@ public class TestClientOperationInterrupt {
threads.add(t);
t.start();
}
+ int expectedNoExNum = nbThread / 2;
for (int i = 0; i < nbThread / 2; i++) {
+ if (threads.get(i).getState().equals(Thread.State.TERMINATED)) {
+ expectedNoExNum--;
+ }
threads.get(i).interrupt();
}
@@ -156,9 +160,8 @@ public class TestClientOperationInterrupt {
}
Assert.assertFalse(Thread.currentThread().isInterrupted());
-
Assert.assertTrue(" noEx: " + noEx.get() + ", badEx=" + badEx.get() + ", noInt=" + noInt.get(),
- noEx.get() == nbThread / 2 && badEx.get() == 0);
+ noEx.get() == expectedNoExNum && badEx.get() == 0);
// The problem here is that we need the server to free its handlers to handle all operations
while (done.get() != nbThread){