You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2022/03/17 17:12:02 UTC
[accumulo-testing] branch main updated: Fixup testing for changes in Accumulo regarding ThreadPools (#197)
This is an automated email from the ASF dual-hosted git repository.
mmiller pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo-testing.git
The following commit(s) were added to refs/heads/main by this push:
new da4a434 Fixup testing for changes in Accumulo regarding ThreadPools (#197)
da4a434 is described below
commit da4a4343d738f4861d7109290d3618f0a09c93b8
Author: Dave Marion <dl...@apache.org>
AuthorDate: Thu Mar 17 13:03:43 2022 -0400
Fixup testing for changes in Accumulo regarding ThreadPools (#197)
---
src/main/java/org/apache/accumulo/testing/randomwalk/Module.java | 3 ++-
src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java | 4 ++--
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/apache/accumulo/testing/randomwalk/Module.java b/src/main/java/org/apache/accumulo/testing/randomwalk/Module.java
index 96ba004..8e85e20 100644
--- a/src/main/java/org/apache/accumulo/testing/randomwalk/Module.java
+++ b/src/main/java/org/apache/accumulo/testing/randomwalk/Module.java
@@ -222,7 +222,8 @@ public class Module extends Node {
fixture.setUp(state, env);
}
- ExecutorService service = ThreadPools.createFixedThreadPool(1, "RandomWalk Runner", false);
+ ExecutorService service = ThreadPools.getServerThreadPools().createFixedThreadPool(1,
+ "RandomWalk Runner", false);
try {
Node initNode = getNode(initNodeId);
diff --git a/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java b/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java
index b39cf7f..ebeb72d 100644
--- a/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java
+++ b/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java
@@ -60,8 +60,8 @@ public class Setup extends Test {
state.set("fs", FileSystem.get(env.getHadoopConfiguration()));
state.set("bulkImportSuccess", "true");
BulkPlusOne.counter.set(0l);
- ThreadPoolExecutor e = ThreadPools.createFixedThreadPool(MAX_POOL_SIZE, "bulkImportPool",
- false);
+ ThreadPoolExecutor e = ThreadPools.getServerThreadPools().createFixedThreadPool(MAX_POOL_SIZE,
+ "bulkImportPool", false);
state.set("pool", e);
}