Skip to content

Commit a42b04d

Browse files
committed
Revert ANY requiring
1 parent 34b4ea2 commit a42b04d

File tree

3 files changed

+8
-4
lines changed

3 files changed

+8
-4
lines changed

ydb/library/yql/dq/opt/dq_opt_phy.cpp

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3486,8 +3486,12 @@ bool ValidateStreamLookupJoinFlags(const TDqJoin& join, TExprContext& ctx) {
34863486
}
34873487

34883488
if (!rightAny) {
3489-
ctx.AddError(TIssue(ctx.GetPosition(join.Pos()), "Streamlookup: must be LEFT JOIN /*+streamlookup(...)*/ ANY"));
3490-
return false;
3489+
if (false) { // Temporary change to waring to allow for smooth transition
3490+
ctx.AddError(TIssue(ctx.GetPosition(join.Pos()), "Streamlookup: must be LEFT JOIN /*+streamlookup(...)*/ ANY"));
3491+
return false;
3492+
} else {
3493+
ctx.AddWarning(TIssue(ctx.GetPosition(join.Pos()), "(Deprecation) Streamlookup: must be LEFT JOIN /*+streamlookup(...)*/ ANY"));
3494+
}
34913495
}
34923496

34933497
return true;

yt/yql/tests/sql/suites/stream_lookup_join/lookup_join.yql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ use plato;
33

44
select e.id as id, e.ts as ts, e.host as host, h.fqdn as fqdn, h.ip4 as ip4, h.ip6 as ip6
55
from Event as e
6-
left join /*+ streamlookup() */ any Host as h
6+
left join /*+ streamlookup() */ Host as h
77
on (e.host == h.hostname)
88
;
99

yt/yql/tests/sql/suites/stream_lookup_join/lookup_join_narrow.yql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ use plato;
33

44
select e.id as id, e.ts as ts, e.host as host, h.fqdn as fqdn, h.ip4 as ip4, h.ip6 as ip6
55
from Event as e
6-
left join /*+ streamlookup() */ any Host as h
6+
left join /*+ streamlookup() */ Host as h
77
on (e.host == h.hostname)
88
;
99

0 commit comments

Comments
 (0)