diff --git a/server/src/test/java/org/elasticsearch/index/engine/InternalEngineTests.java b/server/src/test/java/org/elasticsearch/index/engine/InternalEngineTests.java index c94b4967cb7cf..f0749df406daf 100644 --- a/server/src/test/java/org/elasticsearch/index/engine/InternalEngineTests.java +++ b/server/src/test/java/org/elasticsearch/index/engine/InternalEngineTests.java @@ -4753,6 +4753,9 @@ public void testShouldPeriodicallyFlush() throws Exception { } public void testShouldPeriodicallyFlushAfterMerge() throws Exception { + engine.close(); + // Do not use MockRandomMergePolicy as it can cause a force merge performing two merges. + engine = createEngine(copy(engine.config(), newMergePolicy(random(), false))); assertThat("Empty engine does not need flushing", engine.shouldPeriodicallyFlush(), equalTo(false)); ParsedDocument doc = testParsedDocument(Integer.toString(0), null, testDocumentWithTextField(), SOURCE, null);