@@ -375,15 +375,15 @@ public void testIORateAdjustedForSubmittedTasksWhenExecutionRateIsOnPar() throws
375375 testIORateAdjustedForSubmittedTasks (randomIntBetween (50 , 1000 ), submittedVsExecutedRateOutOf1000 , randomIntBetween (5 , 50 ));
376376 }
377377
378- private void testIORateAdjustedForSubmittedTasks (
379- int totalTasksToSubmit ,
380- int submittedVsExecutedRateOutOf1000 ,
381- int initialTasksToSubmit
382- ) throws IOException {
378+ private void testIORateAdjustedForSubmittedTasks (int totalTasksToSubmit , int submittedVsExecutedRateOutOf1000 , int initialTasksToSubmit )
379+ throws IOException {
383380 DeterministicTaskQueue mergeExecutorTaskQueue = new DeterministicTaskQueue ();
384381 ThreadPool mergeExecutorThreadPool = mergeExecutorTaskQueue .getThreadPool ();
385- ThreadPoolMergeExecutorService threadPoolMergeExecutorService = getThreadPoolMergeExecutorService (mergeExecutorThreadPool ,
386- Settings .EMPTY , newNodeEnvironment (Settings .EMPTY ));
382+ ThreadPoolMergeExecutorService threadPoolMergeExecutorService = getThreadPoolMergeExecutorService (
383+ mergeExecutorThreadPool ,
384+ Settings .EMPTY ,
385+ newNodeEnvironment (Settings .EMPTY )
386+ );
387387 final AtomicInteger currentlySubmittedMergeTaskCount = new AtomicInteger ();
388388 final AtomicLong targetIORateLimit = new AtomicLong (ThreadPoolMergeExecutorService .START_IO_RATE .getBytes ());
389389 final AtomicReference <MergeTask > lastRunTask = new AtomicReference <>();
@@ -527,8 +527,11 @@ public void testThreadPoolStatsWithBackloggedMergeTasks() throws Exception {
527527 .put (EsExecutors .NODE_PROCESSORS_SETTING .getKey (), mergeExecutorThreadCount )
528528 .build ();
529529 try (TestThreadPool testThreadPool = new TestThreadPool ("test" , settings )) {
530- ThreadPoolMergeExecutorService threadPoolMergeExecutorService = getThreadPoolMergeExecutorService (testThreadPool , settings ,
531- newNodeEnvironment (settings ));
530+ ThreadPoolMergeExecutorService threadPoolMergeExecutorService = getThreadPoolMergeExecutorService (
531+ testThreadPool ,
532+ settings ,
533+ newNodeEnvironment (settings )
534+ );
532535 assertThat (threadPoolMergeExecutorService .getMaxConcurrentMerges (), equalTo (mergeExecutorThreadCount ));
533536 int totalMergeTasksCount = randomIntBetween (1 , 10 );
534537 ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor ) testThreadPool .executor (ThreadPool .Names .MERGE );
0 commit comments