diff --git a/core/src/main/java/org/apache/accumulo/core/fate/AbstractFateStore.java b/core/src/main/java/org/apache/accumulo/core/fate/AbstractFateStore.java index 7d368df23b7..96d5805e6e9 100644 --- a/core/src/main/java/org/apache/accumulo/core/fate/AbstractFateStore.java +++ b/core/src/main/java/org/apache/accumulo/core/fate/AbstractFateStore.java @@ -193,12 +193,10 @@ public void runnable(AtomicBoolean keepWaiting, Consumer idConsumer) { if (seen.get() == 0) { if (beforeCount == unreservedRunnableCount.getCount()) { long waitTime = 5000; - synchronized (AbstractFateStore.this) { - if (!deferred.isEmpty()) { - waitTime = deferred.values().stream() - .mapToLong(countDownTimer -> countDownTimer.timeLeft(TimeUnit.MILLISECONDS)).min() - .getAsLong(); - } + if (!deferred.isEmpty()) { + waitTime = deferred.values().stream() + .mapToLong(countDownTimer -> countDownTimer.timeLeft(TimeUnit.MILLISECONDS)).min() + .getAsLong(); } if (waitTime > 0) {