Hi,
可以贴一下flink的版本么？如果方便的话，也可以贴一下plan和最小可复现数据集。
--
Best！
Xuyang
在 2023-12-26 09:25:30，"杨光跃" <yangguangyuem...@163.com> 写道：
>
>
>
>
>
>
>CompiledPlan plan = env.compilePlanSql("insert into out_console " +
>" select r.apply_id from t_purch_apply_sent_route r " +
>" left join t_purch_apply_sent_route_goods FOR SYSTEM_TIME AS OF r.pt as t " +
>"ON t.apply_id = r.apply_id and t.isdel = r.isdel" +
>" where r.apply_id = 61558439941351 and t.route_goods_id is not null and
>t.is_change = 2 " );
>
>
>
>
>
>
>
>
>
>
>
>在 2023-12-25 20:46:36，"Jiabao Sun" <jiabao....@xtransfer.cn.INVALID> 写道：
>>Hi,
>>
>>邮件中的图片没显示出来，麻烦把 SQL 贴出来一下。
>>
>>Best,
>>Jiabao
>>
>>
>>On 2023/12/25 12:22:41 杨光跃 wrote:
>>> 我的sql如下：
>>> 、
>>>
>>>
>>> t_purch_apply_sent_route 是通过flink cdc创建的
>>> t_purch_apply_sent_route_goods 是普通的jdbc
>>> 我期望的结果是返回符合过滤条件的；但现在执行的结果，会返回t_purch_apply_sent_route表所有数据
>>> 这显然不符合我的预期，原因应该是因为过滤条件进行了过早的下推
>>> 这应该算是bug吧，或者要满足我的预期，该怎么写sql?
>>>
>>>
>>>
>>>
