|
@@ -485,7 +485,7 @@ public class InternalEngineTests extends ESTestCase {
|
|
|
|
|
|
if (flush) {
|
|
|
// we should have had just 1 merge, so last generation should be exact
|
|
|
- assertEquals(gen2 + 1, store.readLastCommittedSegmentsInfo().getLastGeneration());
|
|
|
+ assertEquals(gen2, store.readLastCommittedSegmentsInfo().getLastGeneration());
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -843,7 +843,7 @@ public class InternalEngineTests extends ESTestCase {
|
|
|
Engine.SyncedFlushResult.SUCCESS);
|
|
|
assertEquals(3, engine.segments(false).size());
|
|
|
|
|
|
- engine.forceMerge(false, 1, false, false, false);
|
|
|
+ engine.forceMerge(forceMergeFlushes, 1, false, false, false);
|
|
|
if (forceMergeFlushes == false) {
|
|
|
engine.refresh("make all segments visible");
|
|
|
assertEquals(4, engine.segments(false).size());
|