Skip to content

Commit daf6f10

Browse files
committed
Remove invalid test that asserted logic that has been removed
1 parent 0b537c6 commit daf6f10

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/indexing/AsyncTwoPhaseIndexerTests.java

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -268,25 +268,6 @@ public void testStateMachineBrokenSearch() throws InterruptedException {
268268
}
269269
}
270270

271-
public void testStop_AfterIndexerIsFinished() throws InterruptedException {
272-
AtomicReference<IndexerState> state = new AtomicReference<>(IndexerState.STOPPED);
273-
final ExecutorService executor = Executors.newFixedThreadPool(1);
274-
try {
275-
CountDownLatch countDownLatch = new CountDownLatch(1);
276-
MockIndexer indexer = new MockIndexer(executor, state, 2, countDownLatch, false);
277-
indexer.start();
278-
assertTrue(indexer.maybeTriggerAsyncJob(System.currentTimeMillis()));
279-
countDownLatch.countDown();
280-
assertTrue(awaitBusy(() -> isFinished.get()));
281-
282-
indexer.stop();
283-
assertTrue(isStopped.get());
284-
assertThat(indexer.getState(), equalTo(IndexerState.STOPPED));
285-
} finally {
286-
executor.shutdownNow();
287-
}
288-
}
289-
290271
public void testStop_WhileIndexing() throws InterruptedException {
291272
AtomicReference<IndexerState> state = new AtomicReference<>(IndexerState.STOPPED);
292273
final ExecutorService executor = Executors.newFixedThreadPool(1);

0 commit comments

Comments
 (0)