HBASE-24158 [Flakey Tests] TestAsyncTableGetMultiThreaded

thangTang · Apr 16, 2020 · fc6c0d6 · fc6c0d6
1 parent da6c9b1
commit fc6c0d6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...e-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java b/...e-server/src/test/java/org/apache/hadoop/hbase/client/TestAsyncTableGetMultiThreaded.java
@@ -98,7 +98,7 @@ protected static void setUp(MemoryCompactionPolicy memoryCompaction) throws Exce
     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 @@ private void run(AtomicBoolean stop) throws InterruptedException, ExecutionExcep
   @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-"));