Skip to content

Commit f2458af

Browse files
committed
fix sql syntax ydb-platform#10
1 parent 62939a1 commit f2458af

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/tests/fq/generic/streaming/test_join.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -695,14 +695,14 @@ def freeze(json):
695695
u.id as uid, u.age as uage
696696
FROM
697697
$input AS e
698-
LEFT JOIN ANY {streamlookup} ydb_conn_{table_name}.`dby` AS u
698+
LEFT JOIN {streamlookup} ANY ydb_conn_{table_name}.`dby` AS u
699699
ON(e.hash = u.hash)
700700
;
701701
$enriched2 = SELECT e.hash as hash, key, uid, uage,
702702
u2.id as uid2, u2.age as uage2
703703
FROM
704704
$enriched AS e
705-
LEFT JOIN ANY {streamlookup} ydb_conn_{table_name}.`dby` AS u2
705+
LEFT JOIN {streamlookup} ANY ydb_conn_{table_name}.`dby` AS u2
706706
ON(e.hash = u2.hash)
707707
;
708708
$formatTime = DateTime::Format("%Y%m%d%H%M%S");

0 commit comments

Comments
 (0)