FLINK-34170 只是一个UI的展示问题,并不影响实际的运行。 JDBC Connector 维表下推的 filter 不生效问题,已经在 FLINK-33365 中修复了,最新的 JDBC Connector 版本中已经带上了这个修复,你可以试一下~
casel.chen <casel_c...@126.com> 于2024年3月15日周五 10:39写道: > > 我们最近在使用Flink 1.17.1开发flink sql作业维表关联使用复合主键时遇到FLINK-34170描述一样的问题,请问这个major > issue什么时候在哪个版本后能够修复呢?谢谢! > > > select xxx from kafka_table as kt > left join phoenix_table FORSYSTEM_TIMEASOFphoenix_table.proctime as pt > on kt.trans_id=pt.trans_id and pt.trans_date = > DATE_FORMAT(CURRENT_TIMESTAMP,'yyyyMMdd'); > > > phoenix表主键是 trans_id + trans_date > 复合主键,实际作业运行发现flink只会带trans_id字段对phoenix表进行scan查询,再根据scan查询结果按trans_date字段值进行过滤 > > > https://issues.apache.org/jira/browse/FLINK-34170 -- Best, Benchao Li