Skip to content

Commit b528971

Browse files
Remove CrossClusterCancellationIT.createLocalIndex()
createLocalIndex() was added in elastic#121240 but is unused now after testCloseSkipUnavailable() was removed in elastic#123054.
1 parent 768396d commit b528971

File tree

1 file changed

+0
-21
lines changed

1 file changed

+0
-21
lines changed

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

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -81,27 +81,6 @@ private void createRemoteIndex(int numDocs) throws Exception {
8181
bulk.get();
8282
}
8383

84-
private void createLocalIndex(int numDocs) throws Exception {
85-
XContentBuilder mapping = JsonXContent.contentBuilder().startObject();
86-
mapping.startObject("runtime");
87-
{
88-
mapping.startObject("const");
89-
{
90-
mapping.field("type", "long");
91-
mapping.startObject("script").field("source", "").field("lang", "pause").endObject();
92-
}
93-
mapping.endObject();
94-
}
95-
mapping.endObject();
96-
mapping.endObject();
97-
client(LOCAL_CLUSTER).admin().indices().prepareCreate("test").setMapping(mapping).get();
98-
BulkRequestBuilder bulk = client(LOCAL_CLUSTER).prepareBulk("test").setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
99-
for (int i = 0; i < numDocs; i++) {
100-
bulk.add(new IndexRequest().source("foo", i));
101-
}
102-
bulk.get();
103-
}
104-
10584
public void testCancel() throws Exception {
10685
createRemoteIndex(between(10, 100));
10786
EsqlQueryRequest request = EsqlQueryRequest.syncEsqlQueryRequest();

0 commit comments

Comments
 (0)