@@ -460,7 +460,7 @@ public void testMergesRunConcurrently() throws Exception {
460460 // also check the same for the thread-pool executor
461461 assertThat (threadPoolMergeExecutorService .getRunningMergeTasks ().size (), is (mergeSchedulerMaxThreadCount ));
462462 // queued merge tasks do not include backlogged merges
463- assertThat (threadPoolMergeExecutorService .getMergeTasksQueueLength (). size () , is (0 ));
463+ assertThat (threadPoolMergeExecutorService .getMergeTasksQueueLength (), is (0 ));
464464 // also check thread-pool stats for the same
465465 // there are active thread-pool threads waiting for the backlogged merge tasks to be re-enqueued
466466 int activeMergeThreads = Math .min (mergeCount - finalCompletedMergesCount , mergeExecutorThreadCount );
@@ -481,7 +481,7 @@ public void testMergesRunConcurrently() throws Exception {
481481 // also check thread-pool executor for the same
482482 assertThat (threadPoolMergeExecutorService .getRunningMergeTasks ().size (), is (finalRemainingMergesCount ));
483483 // no more backlogged merges
484- assertThat (threadPoolMergeExecutorService .getMergeTasksQueueLength (). size () , is (0 ));
484+ assertThat (threadPoolMergeExecutorService .getMergeTasksQueueLength (), is (0 ));
485485 // also check thread-pool stats for the same
486486 assertThat (threadPoolExecutor .getActiveCount (), is (finalRemainingMergesCount ));
487487 assertThat (threadPoolExecutor .getQueue ().size (), is (0 ));
0 commit comments