(accumulo-testing) branch main updated: Fix deprecated props, use fluent-style threadpool builder (#273)

[domgarguilo]

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 898cded  Fix deprecated props, use fluent-style threadpool builder 
(#273)
898cded is described below

commit 898cdedd5fc1c22cfb755893bda35e91112a994c
Author: Dom G <domgargu...@apache.org>
AuthorDate: Thu Apr 11 14:58:55 2024 -0400

    Fix deprecated props, use fluent-style threadpool builder (#273)
    
    Co-authored-by: Dominic Garguilo <Dominic Garguilo>
---
 src/main/java/org/apache/accumulo/testing/randomwalk/Module.java     | 4 ++--
 src/main/java/org/apache/accumulo/testing/randomwalk/bulk/Setup.java | 4 ++--
 .../org/apache/accumulo/testing/randomwalk/concurrent/Config.java    | 5 ++++-
 3 files changed, 8 insertions(+), 5 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 5861ee2..aec30a3 100644
--- a/src/main/java/org/apache/accumulo/testing/randomwalk/Module.java
+++ b/src/main/java/org/apache/accumulo/testing/randomwalk/Module.java
@@ -220,8 +220,8 @@ public class Module extends Node {
       fixture.setUp(state, env);
     }
 
-    ExecutorService service =
-        ThreadPools.getServerThreadPools().createFixedThreadPool(1, 
"RandomWalk Runner", false);
+    ExecutorService service = 
ThreadPools.getServerThreadPools().getPoolBuilder("RandomWalk Runner")
+        .numCoreThreads(1).build();
 
     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 019ce4a..3c6d46a 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
@@ -61,8 +61,8 @@ public class Setup extends Test {
     state.set("fs", FileSystem.get(env.getHadoopConfiguration()));
     state.set("bulkImportSuccess", "true");
     BulkPlusOne.counter.set(0L);
-    ThreadPoolExecutor e = 
ThreadPools.getServerThreadPools().createFixedThreadPool(MAX_POOL_SIZE,
-        "bulkImportPool", false);
+    ThreadPoolExecutor e = 
ThreadPools.getServerThreadPools().getPoolBuilder("bulkImportPool")
+        .numCoreThreads(MAX_POOL_SIZE).build();
     state.set("pool", e);
   }
 
diff --git 
a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java 
b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java
index ccd3d81..4abba0d 100644
--- 
a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java
+++ 
b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/Config.java
@@ -65,6 +65,9 @@ public class Config extends Test {
   final Property TSERV_COMPACTION_SERVICE_DEFAULT_EXECUTORS_deprecated =
       Property.TSERV_COMPACTION_SERVICE_DEFAULT_EXECUTORS;
 
+  @SuppressWarnings("deprecation")
+  final Property TSERV_WORKQ_THREADS_deprecated = Property.TSERV_WORKQ_THREADS;
+
   // @formatter:off
   final Setting[] settings = {
                        s(Property.TSERV_BLOOM_LOAD_MAXCONCURRENT, 1, 10),
@@ -89,7 +92,7 @@ public class Config extends Test {
                        s(Property.TSERV_WAL_SORT_BUFFER_SIZE, 1024 * 1024, 
1024 * 1024 * 1024L),
                        s(Property.TSERV_TABLET_SPLIT_FINDMIDPOINT_MAXOPEN, 5, 
100),
                        s(Property.TSERV_WAL_BLOCKSIZE, 1024 * 1024,1024 * 1024 
* 1024 * 10L),
-                       s(Property.TSERV_WORKQ_THREADS, 1, 10),
+                       s(TSERV_WORKQ_THREADS_deprecated, 1, 10),
                        s(Property.MANAGER_BULK_TIMEOUT, 10, 600),
                        s(Property.MANAGER_FATE_THREADPOOL_SIZE, 1, 100),
                        s(Property.MANAGER_RECOVERY_DELAY, 0, 100),