This is an automated email from the ASF dual-hosted git repository.
krathbun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit e73a27d575276e04bf1eb9717a9704b6f28d55bc
Merge: 632dbc2ed0 91600dd231
Author: Kevin Rathbun <kevinrr...@gmail.com>
AuthorDate: Mon Dec 16 10:46:54 2024 -0500
Merge remote-tracking branch 'upstream/3.1'
.../java/org/apache/accumulo/core/fate/Fate.java | 2 +-
.../server/conf/CheckAccumuloProperties.java | 66 ++++++++++++++++++++++
2 files changed, 67 insertions(+), 1 deletion(-)
diff --cc core/src/main/java/org/apache/accumulo/core/fate/Fate.java
index 0be6b50eaa,a1f5e26088..a45cb3a405
--- a/core/src/main/java/org/apache/accumulo/core/fate/Fate.java
+++ b/core/src/main/java/org/apache/accumulo/core/fate/Fate.java
@@@ -355,8 -243,7 +355,8 @@@ public class Fate<T>
// 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.getActiveCount();
+ final int configured =
conf.getCount(Property.MANAGER_FATE_THREADPOOL_SIZE);
- final int needed = configured - pool.getQueue().size();
++ final int needed = configured - pool.getActiveCount();
if (needed > 0) {
for (int i = 0; i < needed; i++) {
try {
