Skip to content

Commit

Permalink
fixes a Fate bug:
Browse files Browse the repository at this point in the history
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.
  • Loading branch information
kevinrr888 committed Oct 9, 2024
1 parent 2bec74a commit f3fadf3
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions core/src/main/java/org/apache/accumulo/core/fate/Fate.java
Original file line number Diff line number Diff line change
Expand Up @@ -246,7 +246,7 @@ public void startTransactionRunners(AccumuloConfiguration conf) {
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
Expand All @@ -268,7 +268,7 @@ public void startTransactionRunners(AccumuloConfiguration conf) {
}
}
}
}, 3, SECONDS));
}, 3, 30, SECONDS));
executor = pool;
}

Expand Down

0 comments on commit f3fadf3

Please sign in to comment.