This is an automated email from the ASF dual-hosted git repository. domgarguilo 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 d8c1003 Update usages of ThreadPools.createFixedThreadPool to include new parameter (#189) d8c1003 is described below commit d8c10032acc41cc47879ecf41bcc3193fc386d7d Author: Dom G <dominic.gargu...@gmail.com> AuthorDate: Fri Feb 4 14:08:48 2022 -0500 Update usages of ThreadPools.createFixedThreadPool to include new parameter (#189) --- src/main/java/org/apache/accumulo/testing/randomwalk/Module.java | 2 +- src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java | 3 ++- 2 files changed, 3 insertions(+), 2 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 e77620e..96ba004 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,7 @@ public class Module extends Node { fixture.setUp(state, env); } - ExecutorService service = ThreadPools.createFixedThreadPool(1, "RandomWalk Runner"); + ExecutorService service = ThreadPools.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 ca2e6b6..b39cf7f 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,7 +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"); + ThreadPoolExecutor e = ThreadPools.createFixedThreadPool(MAX_POOL_SIZE, "bulkImportPool", + false); state.set("pool", e); }