We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 043cd71 commit 288f47eCopy full SHA for 288f47e
x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/ManyShardsIT.java
@@ -281,8 +281,7 @@ public void testCancelUnnecessaryRequests() {
281
query.query("from test-* | LIMIT 1");
282
query.pragmas(new QueryPragmas(Settings.builder().put(QueryPragmas.MAX_CONCURRENT_NODES_PER_CLUSTER.getKey(), 1).build()));
283
284
- try {
285
- var result = safeExecute(client(coordinatingNode), EsqlQueryAction.INSTANCE, query);
+ try (var result = safeGet(client().execute(EsqlQueryAction.INSTANCE, query))) {
286
assertThat(Iterables.size(result.rows()), equalTo(1L));
287
assertThat(exchanges.get(), lessThanOrEqualTo(2));
288
} finally {
0 commit comments