From 2d117963809929e9523e47e94b7e5faab7db8e1a Mon Sep 17 00:00:00 2001 From: stack Date: Thu, 9 Apr 2020 11:03:22 -0700 Subject: [PATCH] HBASE-24158 [Flakey Tests] TestAsyncTableGetMultiThreaded --- .../hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java index 7c896957fa..ce6bc05ca0 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java @@ -98,7 +98,7 @@ public class TestAsyncTableGetMultiThreaded { TEST_UTIL.getConfiguration().set(CompactingMemStore.COMPACTING_MEMSTORE_TYPE_KEY, String.valueOf(memoryCompaction)); - TEST_UTIL.startMiniCluster(5); + TEST_UTIL.startMiniCluster(3); SPLIT_KEYS = new byte[8][]; for (int i = 111; i < 999; i += 111) { SPLIT_KEYS[i / 111 - 1] = Bytes.toBytes(String.format("%03d", i)); @@ -134,7 +134,7 @@ public class TestAsyncTableGetMultiThreaded { @Test public void test() throws Exception { LOG.info("====== Test started ======"); - int numThreads = 10; + int numThreads = 7; AtomicBoolean stop = new AtomicBoolean(false); ExecutorService executor = Executors.newFixedThreadPool(numThreads, Threads.newDaemonThreadFactory("TestAsyncGet-")); -- 2.19.1