[CI] Auto commit changes from spotless

Author: elasticsearchmachine

server/src/test/java/org/elasticsearch/index/engine/ThreadPoolMergeExecutorServiceTests.java

@@ -75,12 +75,12 @@ public void testTargetIORateChangesWhenSubmittingMergeTasks() throws Exception {
         int mergesStillToSubmit = randomIntBetween(1, 100);
         int mergesStillToComplete = mergesStillToSubmit;
         Settings settings = Settings.builder()
-                .put(ThreadPoolMergeScheduler.USE_THREAD_POOL_MERGE_SCHEDULER_SETTING.getKey(), true)
-                .put(EsExecutors.NODE_PROCESSORS_SETTING.getKey(), mergeExecutorThreadCount)
-                .build();
+            .put(ThreadPoolMergeScheduler.USE_THREAD_POOL_MERGE_SCHEDULER_SETTING.getKey(), true)
+            .put(EsExecutors.NODE_PROCESSORS_SETTING.getKey(), mergeExecutorThreadCount)
+            .build();
         try (TestThreadPool testThreadPool = new TestThreadPool("test", settings)) {
             ThreadPoolMergeExecutorService threadPoolMergeExecutorService = ThreadPoolMergeExecutorService
-                    .maybeCreateThreadPoolMergeExecutorService(testThreadPool, settings);
+                .maybeCreateThreadPoolMergeExecutorService(testThreadPool, settings);
             assertNotNull(threadPoolMergeExecutorService);
             assertThat(threadPoolMergeExecutorService.getMaxConcurrentMerges(), equalTo(mergeExecutorThreadCount));
             Semaphore runMergeSemaphore = new Semaphore(0);
@@ -118,16 +118,18 @@ public void testTargetIORateChangesWhenSubmittingMergeTasks() throws Exception {
                     }
                     long newIORate = threadPoolMergeExecutorService.getTargetIORateBytesPerSec();
                     if (supportsIOThrottling) {
-                        if (submittedIOThrottledMergeTasks.get() < threadPoolMergeExecutorService.getConcurrentMergesFloorLimitForThrottling()) {
+                        if (submittedIOThrottledMergeTasks.get() < threadPoolMergeExecutorService
+                            .getConcurrentMergesFloorLimitForThrottling()) {
                             // assert the IO rate decreases, with a floor limit, when there are few merge tasks enqueued
                             assertThat(newIORate, either(is(MIN_IO_RATE.getBytes())).or(lessThan(currentIORate)));
-                        } else if (submittedIOThrottledMergeTasks.get() > threadPoolMergeExecutorService.getConcurrentMergesCeilLimitForThrottling()) {
-                            // assert the IO rate increases, with a ceiling limit, when there are many merge tasks enqueued
-                            assertThat(newIORate, either(is(MAX_IO_RATE.getBytes())).or(greaterThan(currentIORate)));
-                        } else {
-                            // assert the IO rate does NOT change when there are a couple of merge tasks enqueued
-                            assertThat(newIORate, equalTo(currentIORate));
-                        }
+                        } else if (submittedIOThrottledMergeTasks.get() > threadPoolMergeExecutorService
+                            .getConcurrentMergesCeilLimitForThrottling()) {
+                                // assert the IO rate increases, with a ceiling limit, when there are many merge tasks enqueued
+                                assertThat(newIORate, either(is(MAX_IO_RATE.getBytes())).or(greaterThan(currentIORate)));
+                            } else {
+                                // assert the IO rate does NOT change when there are a couple of merge tasks enqueued
+                                assertThat(newIORate, equalTo(currentIORate));
+                            }
                     } else {
                         // assert the IO rate does change, when the merge task doesn't support IO throttling
                         assertThat(newIORate, equalTo(currentIORate));

server/src/test/java/org/elasticsearch/index/engine/ThreadPoolMergeSchedulerTests.java

@@ -72,7 +72,12 @@ public void testMergesExecuteInSizeOrder() throws IOException {
                 MergeSource mergeSource = mock(MergeSource.class);
                 MergePolicy.OneMerge oneMerge = mock(MergePolicy.OneMerge.class);
                 when(oneMerge.getStoreMergeInfo()).thenReturn(
-                        new MergeInfo(randomNonNegativeInt(), randomLongBetween(1L, 10L), randomBoolean(), randomFrom(-1, randomNonNegativeInt()))
+                    new MergeInfo(
+                        randomNonNegativeInt(),
+                        randomLongBetween(1L, 10L),
+                        randomBoolean(),
+                        randomFrom(-1, randomNonNegativeInt())
+                    )
                 );
                 when(oneMerge.getMergeProgress()).thenReturn(new MergePolicy.OneMergeProgress());
                 when(mergeSource.getNextMerge()).thenReturn(oneMerge, (MergePolicy.OneMerge) null);
@@ -86,8 +91,10 @@ public void testMergesExecuteInSizeOrder() throws IOException {
             assertThat(executedMergesList.size(), is(mergeCount));
             // assert merges are executed in ascending size order
             for (int i = 1; i < mergeCount; i++) {
-                assertThat(executedMergesList.get(i - 1).getStoreMergeInfo().estimatedMergeBytes(),
-                        lessThanOrEqualTo(executedMergesList.get(i).getStoreMergeInfo().estimatedMergeBytes()));
+                assertThat(
+                    executedMergesList.get(i - 1).getStoreMergeInfo().estimatedMergeBytes(),
+                    lessThanOrEqualTo(executedMergesList.get(i).getStoreMergeInfo().estimatedMergeBytes())
+                );
             }
         }
         assertTrue(threadPoolMergeExecutorService.allDone());