Hi,
可以贴一下flink的版本么？如果方便的话，也可以贴一下plan和最小可复现数据集。
--
Best！
Xuyang
在 2023-12-26 09:25:30，"杨光跃" 写道：
>
>
>
>
>
>
>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
这个问题应该是跟 FLINK-33365[1] 中说的是同一个问题，这个已经在修复中了，在最新的 JDBC Connector 版本中会修复它。
[1] https://issues.apache.org/jira/browse/FLINK-33365
杨光跃 于2023年12月26日周二 09:25写道：
>
>
>
>
>
>
>
> CompiledPlan plan = env.compilePlanSql("insert into out_console " +
> " select r.apply_id from t_purch_apply_sent_route r "
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
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表所有数据
> 这显然不符合我的预期，原因应该是因为过滤条件进行了过早的下推
>
我的sql如下：
、
t_purch_apply_sent_route 是通过flink cdc创建的
t_purch_apply_sent_route_goods 是普通的jdbc
我期望的结果是返回符合过滤条件的；但现在执行的结果，会返回t_purch_apply_sent_route表所有数据
这显然不符合我的预期，原因应该是因为过滤条件进行了过早的下推
这应该算是bug吧，或者要满足我的预期，该怎么写sql?
