This is an automated email from the ASF dual-hosted git repository.
krathbun pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 79d972f83b Fix Fate pool watcher bug (#5171)
79d972f83b is described below
commit 79d972f83b345adbf4cd4b65470d53b8b4f13f98
Author: Kevin Rathbun <krath...@apache.org>
AuthorDate: Mon Dec 16 10:39:50 2024 -0500
Fix Fate pool watcher bug (#5171)
Was incorrectly calculating the number of TransactionRunners to execute
---
core/src/main/java/org/apache/accumulo/core/fate/Fate.java | 2 +-
1 file changed, 1 insertion(+), 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
index 280922a332..8287edbb33 100644
--- 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 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.getQueue().size();
+ int needed = conf.getCount(Property.MANAGER_FATE_THREADPOOL_SIZE) -
pool.getActiveCount();
if (needed > 0) {
for (int i = 0; i < needed; i++) {
try {
