@@ -69,13 +69,13 @@ public void testMergeTasksAreAbortedWhenThreadPoolIsShutdown() {
6969 public void testBackloggedMergeTasksAreAllExecutedExactlyOnce () throws Exception {
7070 int mergeExecutorThreadCount = randomIntBetween (1 , 2 );
7171 Settings settings = Settings .builder ()
72- .put (ThreadPoolMergeScheduler .USE_THREAD_POOL_MERGE_SCHEDULER_SETTING .getKey (), true )
73- // results in few merge threads, in order to increase contention
74- .put (EsExecutors .NODE_PROCESSORS_SETTING .getKey (), mergeExecutorThreadCount )
75- .build ();
72+ .put (ThreadPoolMergeScheduler .USE_THREAD_POOL_MERGE_SCHEDULER_SETTING .getKey (), true )
73+ // results in few merge threads, in order to increase contention
74+ .put (EsExecutors .NODE_PROCESSORS_SETTING .getKey (), mergeExecutorThreadCount )
75+ .build ();
7676 try (TestThreadPool testThreadPool = new TestThreadPool ("test" , settings )) {
7777 ThreadPoolMergeExecutorService threadPoolMergeExecutorService = ThreadPoolMergeExecutorService
78- .maybeCreateThreadPoolMergeExecutorService (testThreadPool , settings );
78+ .maybeCreateThreadPoolMergeExecutorService (testThreadPool , settings );
7979 assertNotNull (threadPoolMergeExecutorService );
8080 assertThat (threadPoolMergeExecutorService .getMaxConcurrentMerges (), equalTo (mergeExecutorThreadCount ));
8181 int mergeTaskCount = randomIntBetween (3 , 30 );
@@ -84,7 +84,7 @@ public void testBackloggedMergeTasksAreAllExecutedExactlyOnce() throws Exception
8484 CountDownLatch submitTaskLatch = new CountDownLatch (1 );
8585 Collection <ThreadPoolMergeScheduler .MergeTask > generatedMergeTasks = ConcurrentCollections .newConcurrentSet ();
8686 for (int i = 0 ; i < mergeTaskCount ; i ++) {
87- new Thread (()-> {
87+ new Thread (() -> {
8888 ThreadPoolMergeScheduler .MergeTask mergeTask = mock (ThreadPoolMergeScheduler .MergeTask .class );
8989 when (mergeTask .isRunning ()).thenReturn (false );
9090 boolean supportsIOThrottling = randomBoolean ();
0 commit comments