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/09 18:18:12 UTC
[hbase] branch branch-2 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
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2 by this push:
new 2d11796 HBASE-24158 [Flakey Tests] TestAsyncTableGetMultiThreaded
2d11796 is described below
commit 2d117963809929e9523e47e94b7e5faab7db8e1a
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-"));