急 [FLINK-34170] 何时能够修复？

Thu, 14 Mar 2024 19:38:49 -0700 

我们最近在使用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

回复