File tree Expand file tree Collapse file tree 1 file changed +1
-12
lines changed
x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action Expand file tree Collapse file tree 1 file changed +1
-12
lines changed Original file line number Diff line number Diff line change 1010import org .apache .lucene .tests .util .LuceneTestCase ;
1111import org .elasticsearch .ExceptionsHelper ;
1212import org .elasticsearch .action .ActionListener ;
13- import org .elasticsearch .action .admin .indices .stats .IndicesStatsRequest ;
1413import org .elasticsearch .action .bulk .BulkRequestBuilder ;
1514import org .elasticsearch .action .support .WriteRequest ;
1615import org .elasticsearch .cluster .metadata .IndexMetadata ;
@@ -283,17 +282,7 @@ public void testCancelUnnecessaryRequests() {
283282 try {
284283 var result = safeExecute (client (coordinatingNode ), EsqlQueryAction .INSTANCE , query );
285284 assertThat (Iterables .size (result .rows ()), equalTo (1L ));
286- assertThat (exchanges .get (), lessThanOrEqualTo (1 ));// 0 if result is populated from coordinating node
287- } catch (AssertionError e ) {
288- client ().admin ().indices ().stats (new IndicesStatsRequest ()).actionGet ().asMap ().forEach ((shard , stats ) -> {
289- logger .info (
290- "Shard {} node {} status {} docs {}" ,
291- shard .shardId (),
292- shard .currentNodeId (),
293- shard .state (),
294- stats .getStats ().getDocs ().getCount ()
295- );
296- });
285+ assertThat (exchanges .get (), lessThanOrEqualTo (2 ));
297286 } finally {
298287 coordinatorNodeTransport .clearAllRules ();
299288 }
You can’t perform that action at this time.
0 commit comments