Skip to content

Commit 5fb05d3

Browse files
Address code review comments
1 parent fbfe052 commit 5fb05d3

File tree

2 files changed

+4
-9
lines changed

2 files changed

+4
-9
lines changed

docs/changelog/135225.yaml

Lines changed: 0 additions & 5 deletions
This file was deleted.

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/analysis/Analyzer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -777,10 +777,10 @@ private Join resolveLookupJoin(LookupJoin join) {
777777
// rewrite the join into an equi-join between the field with the same name between left and right
778778
if (type == JoinTypes.LEFT) {
779779
// the lookup cannot be resolved, bail out
780-
if (Expressions.anyMatch(join.config().leftFields(), c -> c instanceof UnresolvedAttribute ua && ua.customMessage())) {
781-
return join;
782-
}
783-
if (Expressions.anyMatch(join.config().rightFields(), c -> c instanceof UnresolvedAttribute ua && ua.customMessage())) {
780+
if (Expressions.anyMatch(
781+
join.references().stream().toList(),
782+
c -> c instanceof UnresolvedAttribute ua && ua.customMessage()
783+
)) {
784784
return join;
785785
}
786786
List<Attribute> leftKeys = new ArrayList<>();

0 commit comments

Comments
 (0)