Skip to content

Commit a70aff4

Browse files
committed
ensure every shard has at least one doc
1 parent e8ad22a commit a70aff4

File tree

1 file changed

+2
-3
lines changed
  • x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action

1 file changed

+2
-3
lines changed

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/ManyShardsIT.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import org.elasticsearch.ExceptionsHelper;
1212
import org.elasticsearch.action.ActionListener;
1313
import org.elasticsearch.action.bulk.BulkRequestBuilder;
14-
import org.elasticsearch.action.index.IndexRequest;
1514
import org.elasticsearch.action.support.WriteRequest;
1615
import org.elasticsearch.cluster.metadata.IndexMetadata;
1716
import org.elasticsearch.cluster.node.DiscoveryNode;
@@ -93,11 +92,11 @@ public void setupIndices() {
9392
.setMapping("user", "type=keyword", "tags", "type=keyword")
9493
.get();
9594
BulkRequestBuilder bulk = client().prepareBulk(index).setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
96-
int numDocs = between(5, 10);
95+
int numDocs = between(10, 25); // every shard has at least 1 doc
9796
for (int d = 0; d < numDocs; d++) {
9897
String user = randomFrom("u1", "u2", "u3");
9998
String tag = randomFrom("java", "elasticsearch", "lucene");
100-
bulk.add(new IndexRequest().source(Map.of("user", user, "tags", tag)));
99+
bulk.add(client().prepareIndex().setSource(Map.of("user", user, "tags", tag)));
101100
}
102101
bulk.get();
103102
}

0 commit comments

Comments
 (0)