File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
server/src/main/java/org/elasticsearch/index/engine Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -87,8 +87,8 @@ public class ThreadPoolMergeExecutorService {
8787 private ThreadPoolMergeExecutorService (ThreadPool threadPool ) {
8888 this .executorService = threadPool .executor (ThreadPool .Names .MERGE );
8989 this .maxConcurrentMerges = threadPool .info (ThreadPool .Names .MERGE ).getMax ();
90- this .concurrentMergesFloorLimitForThrottling = maxConcurrentMerges * 2 ;
91- this .concurrentMergesCeilLimitForThrottling = maxConcurrentMerges * 4 ;
90+ this .concurrentMergesFloorLimitForThrottling = 2 ;
91+ this .concurrentMergesCeilLimitForThrottling = maxConcurrentMerges * 2 ;
9292 }
9393
9494 boolean submitMergeTask (MergeTask mergeTask ) {
@@ -230,10 +230,10 @@ private static long newTargetIORateBytesPerSec(
230230 );
231231 } else if (currentlySubmittedIOThrottledMergeTasks > concurrentMergesCeilLimitForThrottling
232232 && currentTargetIORateBytesPerSec < MAX_IO_RATE .getBytes ()) {
233- // increase target IO rate by 10 % (capped)
233+ // increase target IO rate by 20 % (capped)
234234 newTargetIORateBytesPerSec = Math .min (
235235 MAX_IO_RATE .getBytes (),
236- currentTargetIORateBytesPerSec + currentTargetIORateBytesPerSec / 10L
236+ currentTargetIORateBytesPerSec + currentTargetIORateBytesPerSec / 20L
237237 );
238238 } else {
239239 newTargetIORateBytesPerSec = currentTargetIORateBytesPerSec ;
You can’t perform that action at this time.
0 commit comments