请问下lookup join报 ‘Processing-time temporal join is not supported yet’是什么原因呢,版本1.13.6
Flink SQL 目前还不支持 "processing-time temporal join",即处理时间的时态表关联。这是因为 processing-time temporal join 在语义上要求先处理完 temporal table 的历史数据(bootstrap state),再处理事实表的数据和temporal table的增量数据,目前Flink在底层还不支持如此灵活的调度模型。
不过 Flink SQL 支持 event-time temporal join,要求"FOR SYSTEM AS OF" 的字段是一个 event time attribute。另外 Flink SQL 也支持 lookup join,要求被temporal join 的表是一个支持了 lookup 数据源。
你可以添加手动添加一个时间,然后利用这个手动添加的时间去做关联(此答案整理自Flink CDC 社区)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。