已解决 where 条件始终为假。
--
发件人:silence
发送时间:2021年7月7日(星期三) 12:05
收件人:user-zh
主 题:flinksql问题请教
请教一下下面的sql为什么会被翻译成有限数据集?源表是个kafka source,用了row_number进行开窗和两次Table Function join
flink版本:1.12.2
Stage 1 : Data Source
content : Source: Values
请教一下下面的sql为什么会被翻译成有限数据集?源表是个kafka source,用了row_number进行开窗和两次Table Function join
flink版本:1.12.2
Stage 1 : Data Source
content : Source: Values(tuples=[[]])
Stage 2 : Operator
content : Correlate(invocation=[LateralArray($cor3.gift_list)],
correlate=[table(LateralArray($cor3.gift_list))],
select=