(accumulo) branch 2.1 updated: fixes a Fate bug: (#4965)

[krathbun]

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 68cb5aaeba fixes a Fate bug: (#4965)
68cb5aaeba is described below

commit 68cb5aaeba7295a96b7c9fa3cdd36ef0de46c15f
Author: Kevin Rathbun <krath...@apache.org>
AuthorDate: Mon Oct 21 09:42:53 2024 -0400

    fixes a Fate bug: (#4965)
    
    fixes an issue with how new fate transaction runners are created if one 
dies. Prior to this commit, the check for dead transaction runners would only 
occur once. This now occurs periodically.
---
 core/src/main/java/org/apache/accumulo/core/fate/Fate.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 4eb690e5b2..280922a332 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
@@ -246,7 +246,7 @@ public class Fate<T> {
         Property.MANAGER_FATE_THREADPOOL_SIZE, true);
     fatePoolWatcher =
         
ThreadPools.getServerThreadPools().createGeneralScheduledExecutorService(conf);
-    ThreadPools.watchCriticalScheduledTask(fatePoolWatcher.schedule(() -> {
+    
ThreadPools.watchCriticalScheduledTask(fatePoolWatcher.scheduleWithFixedDelay(()
 -> {
       // 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
@@ -268,7 +268,7 @@ public class Fate<T> {
           }
         }
       }
-    }, 3, SECONDS));
+    }, 3, 30, SECONDS));
     executor = pool;
   }