[CI] Auto commit changes from spotless

Author: elasticsearchmachine

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

@@ -338,10 +338,10 @@ public void testBackloggedMergeTasksDoNotHoldUpBudget() throws Exception {
         bFileStore.usableSpace = randomLongBetween(10L, bFileStore.totalSpace);
         boolean aHasMoreSpace = aFileStore.usableSpace > bFileStore.usableSpace;
         Settings settings = Settings.builder()
-                .put(this.settings)
-                // the default of "5s" slows down testing
-                .put(ThreadPoolMergeExecutorService.INDICES_MERGE_DISK_CHECK_INTERVAL_SETTING.getKey(), "30ms")
-                .build();
+            .put(this.settings)
+            // the default of "5s" slows down testing
+            .put(ThreadPoolMergeExecutorService.INDICES_MERGE_DISK_CHECK_INTERVAL_SETTING.getKey(), "30ms")
+            .build();
         try (TestThreadPool testThreadPool = new TestThreadPool("test", settings)) {
             try (NodeEnvironment nodeEnv = new NodeEnvironment(settings, TestEnvironment.newEnvironment(settings))) {
                 try (
@@ -408,9 +408,8 @@ && randomBoolean()) {
                         doAnswer(mock -> {
                             // maybe re-enqueue backlogged merge task
                             if (randomBoolean()) {
-                                testThreadPool.executor(ThreadPool.Names.GENERIC).execute(() -> {
-                                    threadPoolMergeExecutorService.reEnqueueBackloggedMergeTask(mergeTask);
-                                });
+                                testThreadPool.executor(ThreadPool.Names.GENERIC)
+                                    .execute(() -> { threadPoolMergeExecutorService.reEnqueueBackloggedMergeTask(mergeTask); });
                             }
                             // always backlog these merge tasks
                             return BACKLOG;
@@ -420,22 +419,20 @@ && randomBoolean()) {
                     }
                     // assert all backlogging merge tasks have been scheduled and possibly re-enqueued, none run and none aborted,
                     // AND the available budget is intact
-                    assertBusy(
-                        () -> {
-                            for (ThreadPoolMergeScheduler.MergeTask mergeTask : backloggingMergeTasks) {
-                                verify(mergeTask, atLeastOnce()).schedule();
-                            }
-                            for (ThreadPoolMergeScheduler.MergeTask mergeTask : backloggingMergeTasks) {
-                                verify(mergeTask, times(0)).run();
-                                verify(mergeTask, times(0)).abort();
-                            }
-                            // budget hasn't changed!
-                            assertThat(
-                                threadPoolMergeExecutorService.getDiskSpaceAvailableForNewMergeTasks(),
-                                is(expectedAvailableBudget.get())
-                            );
+                    assertBusy(() -> {
+                        for (ThreadPoolMergeScheduler.MergeTask mergeTask : backloggingMergeTasks) {
+                            verify(mergeTask, atLeastOnce()).schedule();
                         }
-                    );
+                        for (ThreadPoolMergeScheduler.MergeTask mergeTask : backloggingMergeTasks) {
+                            verify(mergeTask, times(0)).run();
+                            verify(mergeTask, times(0)).abort();
+                        }
+                        // budget hasn't changed!
+                        assertThat(
+                            threadPoolMergeExecutorService.getDiskSpaceAvailableForNewMergeTasks(),
+                            is(expectedAvailableBudget.get())
+                        );
+                    });
                     // double check that submitting a runnable merge task under budget works correctly
                     ThreadPoolMergeScheduler.MergeTask mergeTask = mock(ThreadPoolMergeScheduler.MergeTask.class);
                     long taskBudget = randomLongBetween(1L, backloggedMergeTaskDiskSpaceBudget);