File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
x-pack/plugin/rollup/src/test/java/org/elasticsearch/xpack/rollup/job Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 31
31
import org .elasticsearch .xpack .core .rollup .job .RollupIndexerJobStats ;
32
32
import org .elasticsearch .xpack .core .rollup .job .RollupJob ;
33
33
import org .elasticsearch .xpack .core .rollup .job .RollupJobConfig ;
34
+ import org .hamcrest .Matchers ;
34
35
import org .mockito .stubbing .Answer ;
35
36
36
37
import java .io .IOException ;
@@ -644,7 +645,7 @@ protected void onAbort() {
644
645
final CountDownLatch latch = indexer .newLatch ();
645
646
assertTrue (indexer .maybeTriggerAsyncJob (System .currentTimeMillis ()));
646
647
assertThat (indexer .stop (), equalTo (IndexerState .STOPPING ));
647
- assertThat (indexer .getState (), equalTo ( IndexerState .STOPPING ));
648
+ assertThat (indexer .getState (), Matchers . either ( Matchers . is ( IndexerState .STOPPING )). or ( Matchers . is ( IndexerState . STOPPED ) ));
648
649
latch .countDown ();
649
650
assertBusy (() -> assertThat (indexer .getState (), equalTo (IndexerState .STOPPED )));
650
651
assertTrue (indexer .abort ());
You can’t perform that action at this time.
0 commit comments