This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/main by this push:
new 7732758a60 fixes Fate burning CPU when no ranges assigned (#6300)
7732758a60 is described below
commit 7732758a6099b3d19610e14ccc640ab29016543b
Author: Keith Turner <[email protected]>
AuthorDate: Wed Apr 8 07:54:56 2026 -0700
fixes Fate burning CPU when no ranges assigned (#6300)
The complete meta fate range is only assigned to one assistant manager.
The other assistant managers are assigned an empty set of ranges for meta
fate. The managers with nothing assigned were burning 300% CPU.
---
core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
b/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
index 2457095209..de4bf9c995 100644
--- a/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
+++ b/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
@@ -318,6 +318,10 @@ public class FateExecutor<T> {
while (fate.getKeepRunning().get() && !isShutdown()) {
try {
var localPartitions = partitions.get();
+ if (localPartitions.isEmpty()) {
+ Thread.sleep(250);
+ continue;
+ }
// if the set of partitions changes, we should stop looking for work
w/ the old set of
// partitions
BooleanSupplier keepRunning =
