Skip to content

Commit dcb0913

Browse files
authored
Fix testBadAsyncId (#132705)
1 parent 19b61ef commit dcb0913

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

muted-tests.yml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -462,9 +462,6 @@ tests:
462462
- class: org.elasticsearch.xpack.ml.integration.AutodetectMemoryLimitIT
463463
method: testTooManyByAndOverFields
464464
issue: https://github.com/elastic/elasticsearch/issues/132310
465-
- class: org.elasticsearch.xpack.esql.action.CrossClusterAsyncQueryIT
466-
method: testBadAsyncId
467-
issue: https://github.com/elastic/elasticsearch/issues/132353
468465
- class: org.elasticsearch.xpack.esql.inference.completion.CompletionOperatorTests
469466
method: testSimpleCircuitBreaking
470467
issue: https://github.com/elastic/elasticsearch/issues/132382

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlExecutionInfo.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,9 @@ public EsqlExecutionInfo(StreamInput in) throws IOException {
124124
public void writeTo(StreamOutput out) throws IOException {
125125
out.writeOptionalTimeValue(overallTook);
126126
if (clusterInfo != null) {
127-
out.writeCollection(clusterInfo.values());
127+
// .stream().toList() creates an immutable copy of the cluster info entries
128+
// as today they might be still changing while serialization is happening
129+
out.writeCollection(clusterInfo.values().stream().toList());
128130
} else {
129131
out.writeCollection(Collections.emptyList());
130132
}

0 commit comments

Comments
 (0)