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 <dlmar...@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); }