@@ -218,12 +218,12 @@ private ThreadPoolMergeExecutorService(
218218 assert concurrentMergesFloorLimitForThrottling <= concurrentMergesCeilLimitForThrottling ;
219219 this .budgetTracker = new BudgetTracker <>(MergeTask ::estimatedRemainingMergeSize , Long .MAX_VALUE , queuedMergeTasks ::add );
220220 this .availableDiskSpacePeriodicMonitor = new AvailableDiskSpacePeriodicMonitor (
221- nodeEnvironment .dataPaths (),
222- threadPool ,
223- INDICES_MERGE_DISK_HIGH_WATERMARK_SETTING .get (settings ),
224- INDICES_MERGE_DISK_HIGH_MAX_HEADROOM_SETTING .get (settings ),
225- INDICES_MERGE_DISK_CHECK_INTERVAL_SETTING .get (settings ),
226- (availableDiskSpaceByteSize ) -> budgetTracker .updateBudget (availableDiskSpaceByteSize .getBytes ())
221+ nodeEnvironment .dataPaths (),
222+ threadPool ,
223+ INDICES_MERGE_DISK_HIGH_WATERMARK_SETTING .get (settings ),
224+ INDICES_MERGE_DISK_HIGH_MAX_HEADROOM_SETTING .get (settings ),
225+ INDICES_MERGE_DISK_CHECK_INTERVAL_SETTING .get (settings ),
226+ (availableDiskSpaceByteSize ) -> budgetTracker .updateBudget (availableDiskSpaceByteSize .getBytes ())
227227 );
228228 clusterSettings .addSettingsUpdateConsumer (
229229 INDICES_MERGE_DISK_HIGH_WATERMARK_SETTING ,
@@ -471,9 +471,9 @@ private void run() {
471471 }
472472
473473 private static ByteSizeValue getFreeBytesThreshold (
474- ByteSizeValue total ,
475- RelativeByteSizeValue watermark ,
476- ByteSizeValue maxHeadroom
474+ ByteSizeValue total ,
475+ RelativeByteSizeValue watermark ,
476+ ByteSizeValue maxHeadroom
477477 ) {
478478 // If bytes are given, they can be readily returned as free bytes.
479479 // If percentages are given, we need to calculate the free bytes.
0 commit comments