回复：flinksql问题请教

已解决 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

flinksql问题请教

请教一下下面的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))],