Skip to content

Commit 0f05be8

Browse files
committed
Fixed generic provider tests
1 parent d638e1c commit 0f05be8

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -539,7 +539,7 @@ def freeze(json):
539539
e.Data as data, u.id as lookup
540540
from
541541
$input as e
542-
left join {streamlookup} ydb_conn_{table_name}.{table_name} as u
542+
left join {streamlookup} any ydb_conn_{table_name}.{table_name} as u
543543
on(AsList(e.Data) = u.data)
544544
-- MultiGet true
545545
;
@@ -582,7 +582,7 @@ def freeze(json):
582582
u.data as lookup
583583
from
584584
$input as e
585-
left join {streamlookup} ydb_conn_{table_name}.{table_name} as u
585+
left join {streamlookup} any ydb_conn_{table_name}.{table_name} as u
586586
on(e.user = u.id)
587587
-- MultiGet true
588588
;
@@ -656,7 +656,7 @@ def freeze(json):
656656
u.data as lookup
657657
from
658658
$input as e
659-
left join {streamlookup} ydb_conn_{table_name}.{table_name} as u
659+
left join {streamlookup} any ydb_conn_{table_name}.{table_name} as u
660660
on(e.user = u.id)
661661
-- MultiGet true
662662
;
@@ -713,7 +713,7 @@ def freeze(json):
713713
$enriched = select a, b, c, d, e, f, za, yb, yc, zd
714714
from
715715
$input as e
716-
left join {streamlookup} $listified as u
716+
left join {streamlookup} any $listified as u
717717
on(e.za = u.a AND e.yb = u.b)
718718
-- MultiGet true
719719
;
@@ -760,9 +760,9 @@ def freeze(json):
760760
$enriched = select u.a as la, u.b as lb, u.c as lc, u2.a as sa, u2.b as sb, u2.c as sc, lza, lyb, sza, syb, yc
761761
from
762762
$input as e
763-
left join {streamlookup} $listified as u
763+
left join {streamlookup} any $listified as u
764764
on(e.lza = u.a AND e.lyb = u.b)
765-
left join /*+streamlookup()*/ $listified as u2
765+
left join /*+streamlookup()*/ any $listified as u2
766766
on(e.sza = u2.a AND e.syb = u2.b)
767767
-- MultiGet true
768768
;

0 commit comments

Comments
 (0)