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

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


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

commit 67b2e881cabc243a096772938fec977c433f086e
Author: stack <[email protected]>
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-"));

Reply via email to