diff --git a/muted-tests.yml b/muted-tests.yml index 8023d2cff90fa..a0515b2e9aaa5 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -462,9 +462,6 @@ tests: - class: org.elasticsearch.xpack.ml.integration.AutodetectMemoryLimitIT method: testTooManyByAndOverFields issue: https://github.com/elastic/elasticsearch/issues/132310 -- class: org.elasticsearch.xpack.esql.action.CrossClusterAsyncQueryIT - method: testBadAsyncId - issue: https://github.com/elastic/elasticsearch/issues/132353 - class: org.elasticsearch.xpack.esql.inference.completion.CompletionOperatorTests method: testSimpleCircuitBreaking issue: https://github.com/elastic/elasticsearch/issues/132382 diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlExecutionInfo.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlExecutionInfo.java index 9ac56ad433872..1596bd3f64d91 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlExecutionInfo.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlExecutionInfo.java @@ -124,7 +124,9 @@ public EsqlExecutionInfo(StreamInput in) throws IOException { public void writeTo(StreamOutput out) throws IOException { out.writeOptionalTimeValue(overallTook); if (clusterInfo != null) { - out.writeCollection(clusterInfo.values()); + // .stream().toList() creates an immutable copy of the cluster info entries + // as today they might be still changing while serialization is happening + out.writeCollection(clusterInfo.values().stream().toList()); } else { out.writeCollection(Collections.emptyList()); }