File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -282,8 +282,7 @@ public void testCancelUnnecessaryRequests() {
282
282
query .query ("from test-* | LIMIT 1" );
283
283
query .pragmas (new QueryPragmas (Settings .builder ().put (QueryPragmas .MAX_CONCURRENT_NODES_PER_CLUSTER .getKey (), 1 ).build ()));
284
284
285
- try {
286
- var result = safeExecute (client (coordinatingNode ), EsqlQueryAction .INSTANCE , query );
285
+ try (var result = safeGet (client ().execute (EsqlQueryAction .INSTANCE , query ))) {
287
286
assertThat (Iterables .size (result .rows ()), equalTo (1L ));
288
287
assertThat (exchanges .get (), lessThanOrEqualTo (1 ));// 0 if result is populated from coordinating node
289
288
} catch (AssertionError e ) {
You can’t perform that action at this time.
0 commit comments