You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2020/04/13 18:52:24 UTC

[hbase] branch branch-2.3 updated: HBASE-24158 [Flakey Tests] TestAsyncTableGetMultiThreaded

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

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


The following commit(s) were added to refs/heads/branch-2.3 by this push:
     new 7b2b6dc  HBASE-24158 [Flakey Tests] TestAsyncTableGetMultiThreaded
7b2b6dc is described below

commit 7b2b6dcf97e0268990eddf6c81dc0c13be7e5e0b
Author: stack <st...@apache.org>
AuthorDate: Thu Apr 9 11:03:22 2020 -0700

    HBASE-24158 [Flakey Tests] TestAsyncTableGetMultiThreaded
---
 .../apache/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 7c89695..ce6bc05 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-"));