From 22526e93ed4ffc6ceabefd7a59ed09cdfb36f000 Mon Sep 17 00:00:00 2001 From: Xu cang Date: Wed, 27 Feb 2019 13:19:13 -0800 Subject: [PATCH] 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 72b74fb..39f7c92 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 @@ -127,8 +127,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(); } @@ -145,9 +149,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){ -- 2.7.4