You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by do...@apache.org on 2022/02/04 19:08:55 UTC
[accumulo-testing] branch main updated: Update usages of ThreadPools.createFixedThreadPool to include new parameter (#189)
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 <do...@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);
}