Skip to content

Commit 0487181

Browse files
committed
[TEST] Force flush to ensure multiple segments.
Relates to #35333
1 parent 3229dfc commit 0487181

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/action/ShardChangesTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
package org.elasticsearch.xpack.ccr.action;
77

88
import org.elasticsearch.ElasticsearchException;
9+
import org.elasticsearch.action.admin.indices.flush.FlushRequest;
910
import org.elasticsearch.action.admin.indices.forcemerge.ForceMergeRequest;
1011
import org.elasticsearch.action.admin.indices.refresh.RefreshRequest;
1112
import org.elasticsearch.action.admin.indices.stats.ShardStats;
@@ -99,6 +100,7 @@ public void testMissingOperations() {
99100
for (int i = 0; i < 32; i++) {
100101
client().prepareIndex("index", "_doc", "1").setSource("{}", XContentType.JSON).get();
101102
client().prepareDelete("index", "_doc", "1").get();
103+
client().admin().indices().flush(new FlushRequest("index").force(true)).actionGet();
102104
}
103105
client().admin().indices().refresh(new RefreshRequest("index")).actionGet();
104106
ForceMergeRequest forceMergeRequest = new ForceMergeRequest("index");

0 commit comments

Comments
 (0)