Skip to content

Commit a17fa88

Browse files
Fix UT error
1 parent d9462cc commit a17fa88

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/enrich/LookupFromIndexService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,7 @@ static TransportRequest readFrom(StreamInput in, BlockFactory blockFactory) thro
205205
}
206206
List<LookupFromIndexOperator.MatchConfig> matchFields = null;
207207
if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_LOOKUP_JOIN_ON_MANY_FIELDS)) {
208-
matchFields = in.readCollectionAsList(LookupFromIndexOperator.MatchConfig::new);
208+
matchFields = planIn.readCollectionAsList(LookupFromIndexOperator.MatchConfig::new);
209209
} else {
210210
// For older versions, we only support a single match field.
211211
matchFields = new ArrayList<>(1);
@@ -250,7 +250,7 @@ public void writeTo(StreamOutput out) throws IOException {
250250
out.writeString(source.text());
251251
}
252252
if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_LOOKUP_JOIN_ON_MANY_FIELDS)) {
253-
out.writeCollection(matchFields, (o, matchConfig) -> matchConfig.writeTo(o));
253+
planOut.writeCollection(matchFields, (o, matchConfig) -> matchConfig.writeTo(o));
254254
}
255255
}
256256

0 commit comments

Comments
 (0)