File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
server/src/test/java/org/elasticsearch/index/engine Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 3030import java .io .IOException ;
3131import java .util .ArrayList ;
3232import java .util .List ;
33- import java .util .concurrent .CountDownLatch ;
3433import java .util .concurrent .Semaphore ;
3534import java .util .concurrent .ThreadPoolExecutor ;
3635import java .util .concurrent .atomic .AtomicBoolean ;
@@ -215,7 +214,8 @@ public void testMergesRunConcurrently() throws Exception {
215214 }).when (mergeSource ).merge (any (OneMerge .class ));
216215 threadPoolMergeScheduler .merge (mergeSource , randomFrom (MergeTrigger .values ()));
217216 }
218- for (int completedMergesCount = 0 ; completedMergesCount < mergeCount - mergeSchedulerMaxThreadCount ; completedMergesCount ++) {
217+ for (int completedMergesCount = 0 ; completedMergesCount < mergeCount
218+ - mergeSchedulerMaxThreadCount ; completedMergesCount ++) {
219219 int finalCompletedMergesCount = completedMergesCount ;
220220 assertBusy (() -> {
221221 // assert that there are merges running concurrently at the max allowed concurrency rate
You can’t perform that action at this time.
0 commit comments