Skip to content

Commit edc36aa

Browse files
authored
Fix testCancelUnnecessaryRequests (#124864)
1 parent ec0f8be commit edc36aa

File tree

1 file changed

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

1 file changed

+1
-12
lines changed

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

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
import org.apache.lucene.tests.util.LuceneTestCase;
1111
import org.elasticsearch.ExceptionsHelper;
1212
import org.elasticsearch.action.ActionListener;
13-
import org.elasticsearch.action.admin.indices.stats.IndicesStatsRequest;
1413
import org.elasticsearch.action.bulk.BulkRequestBuilder;
1514
import org.elasticsearch.action.support.WriteRequest;
1615
import 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
}

0 commit comments

Comments
 (0)