diff --git a/server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeScheduler.java b/server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeScheduler.java index a10afd98f8585..9e490037b55e4 100644 --- a/server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeScheduler.java +++ b/server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeScheduler.java @@ -186,7 +186,7 @@ private void maybeActivateThrottling() { private void maybeDeactivateThrottling() { int numActiveMerges = activeMergeTasksExecutingOnLocalSchedulerList.size(); - if (numActiveMerges <= config.getMaxMergeCount() && isThrottling.getAndSet(false) == true) { + if (numActiveMerges <= config.getMaxMergeCount() && isThrottling.getAndSet(false)) { deactivateThrottling(numActiveMerges); } }