这个问题应该是跟 FLINK-33365[1] 中说的是同一个问题，这个已经在修复中了，在最新的 JDBC Connector 版本中会修复它。
[1] https://issues.apache.org/jira/browse/FLINK-33365 杨光跃 <yangguangyuem...@163.com> 于2023年12月26日周二 09:25写道： > > > > > > > > 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? > >> > >> > >> > >> -- Best, Benchao Li
