diff --git a/muted-tests.yml b/muted-tests.yml index cd79ef6bc0713..5a3865a3af0b1 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -453,9 +453,6 @@ tests: - class: org.elasticsearch.cluster.routing.allocation.decider.DiskThresholdDeciderIT method: testRestoreSnapshotAllocationDoesNotExceedWatermarkWithMultipleRestores issue: https://github.com/elastic/elasticsearch/issues/127787 -- class: org.elasticsearch.xpack.esql.action.CrossClusterQueryWithFiltersIT - method: testTimestampFilterFromQuery - issue: https://github.com/elastic/elasticsearch/issues/127332 - class: org.elasticsearch.indices.stats.IndexStatsIT method: testThrottleStats issue: https://github.com/elastic/elasticsearch/issues/126359 diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlCCSUtils.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlCCSUtils.java index ccbfeaccf24a9..5e32ef5afac4a 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlCCSUtils.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlCCSUtils.java @@ -350,9 +350,9 @@ public static void markClusterWithFinalStateAndNoShards( Cluster.Builder builder = new Cluster.Builder(v).setStatus(status) .setTook(executionInfo.tookSoFar()) .setTotalShards(Objects.requireNonNullElse(v.getTotalShards(), 0)) - .setSuccessfulShards(Objects.requireNonNullElse(v.getTotalShards(), 0)) - .setSkippedShards(Objects.requireNonNullElse(v.getTotalShards(), 0)) - .setFailedShards(Objects.requireNonNullElse(v.getTotalShards(), 0)); + .setSuccessfulShards(Objects.requireNonNullElse(v.getSuccessfulShards(), 0)) + .setSkippedShards(Objects.requireNonNullElse(v.getSkippedShards(), 0)) + .setFailedShards(Objects.requireNonNullElse(v.getFailedShards(), 0)); if (ex != null) { builder.setFailures(List.of(new ShardSearchFailure(ex))); }