请问下lookup join报 ‘Processing-time temporal join is[阿里云实时计算 Flink版]

请问下lookup join报 ‘Processing-time temporal join is not supported yet’是什么原因呢,版本1.13.6

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
15 条回复 A 作者 M 管理员
  1. 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 数据源。

  2. 感谢分享

  3. 没遇到过

  4. 感谢分享感谢分享

  5. 感谢分享感谢分享

  6. 感谢分享感谢分享

  7. 感谢分享感谢分享

  8. 感谢分享感谢分享

  9. 感谢分享感谢分享

  10. 感谢分享感谢分享

  11. 感谢分享感谢分享

  12. 感谢分享感谢分享

  13. 查查资料吧

  14. 这个还真没遇到过

  15. 你可以添加手动添加一个时间,然后利用这个手动添加的时间去做关联(此答案整理自Flink CDC 社区)

  16. 就是Flink SQL还不支持呀。。。(此答案整理自Flink CDC 社区)