diff --git a/x-pack/plugin/esql/qa/server/single-node/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/single_node/StoredFieldsSequentialIT.java b/x-pack/plugin/esql/qa/server/single-node/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/single_node/StoredFieldsSequentialIT.java index 19db8b798cfad..27073e302de0d 100644 --- a/x-pack/plugin/esql/qa/server/single-node/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/single_node/StoredFieldsSequentialIT.java +++ b/x-pack/plugin/esql/qa/server/single-node/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/single_node/StoredFieldsSequentialIT.java @@ -194,6 +194,15 @@ public void buildIndex() throws IOException { bulk.setJsonEntity(b.toString()); Response bulkResponse = client().performRequest(bulk); assertThat(entityToMap(bulkResponse.getEntity(), XContentType.JSON), matchesMap().entry("errors", false).extraOk()); + + // Forcemerge to one segment to get more consistent results. + Request forcemerge = new Request("POST", "/_forcemerge"); + forcemerge.addParameter("max_num_segments", "1"); + Response forcemergeResponse = client().performRequest(forcemerge); + assertThat( + entityToMap(forcemergeResponse.getEntity(), XContentType.JSON), + matchesMap().entry("_shards", matchesMap().entry("failed", 0).entry("successful", greaterThanOrEqualTo(1)).extraOk()).extraOk() + ); } @Override