Merge branch '3.1'

apache · Oct 21, 2024 · 56e3a61 · 56e3a61
2 parents ab5c57e + d7cbdec
commit 56e3a61
Showing 1 changed file with 2 additions and 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
@@ -352,7 +352,7 @@ public Fate(T environment, FateStore<T> store, boolean runDeadResCleaner,
     this.workQueue = new LinkedTransferQueue<>();
     this.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
@@ -374,7 +374,7 @@ public Fate(T environment, FateStore<T> store, boolean runDeadResCleaner,
           }
         }
       }
-    }, 3, SECONDS));
+    }, 3, 30, SECONDS));
     this.transactionExecutor = pool;
 
     ScheduledExecutorService deadResCleanerExecutor = null;