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-"));