Fix Fate pool watcher bug

Was incorrectly calculating the number of TransactionRunners to execute
apache · Dec 12, 2024 · 6f9bea0 · 6f9bea0
1 parent be9fa22
commit 6f9bea0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/java/org/apache/accumulo/core/fate/Fate.java b/core/src/main/java/org/apache/accumulo/core/fate/Fate.java
@@ -250,7 +250,7 @@ public void startTransactionRunners(AccumuloConfiguration conf) {
       // resize the pool if the property changed
       ThreadPools.resizePool(pool, conf, Property.MANAGER_FATE_THREADPOOL_SIZE);
       // If the pool grew, then ensure that there is a TransactionRunner for each thread
-      int needed = conf.getCount(Property.MANAGER_FATE_THREADPOOL_SIZE) - pool.getQueue().size();
+      int needed = conf.getCount(Property.MANAGER_FATE_THREADPOOL_SIZE) - pool.getActiveCount();
       if (needed > 0) {
         for (int i = 0; i < needed; i++) {
           try {