开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请问下lookup join报 ‘Processing-time temporal join is

已解决

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

展开
收起
游客3oewgrzrf6o5c 2022-08-22 17:35:47 35504 24
16 条回答
写回答
取消 提交回答
  • 个人博客: http://wuchong.me
    推荐回答

    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 数据源。

    2023-02-08 10:15:39
    赞同 3 展开评论 打赏
  • 感谢分享

    2023-01-10 14:57:58
    赞同 2 展开评论 打赏
  • 没遇到过

    2022-08-26 08:35:01
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 13:07:07
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 13:07:43
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 13:03:45
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 13:03:19
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 13:00:29
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 12:59:17
    赞同 1 展开评论 打赏
  • 无所不能的蛋蛋

    感谢分享感谢分享

    2022-08-24 12:58:01
    赞同 1 展开评论 打赏
  • 感谢分享感谢分享

    2022-08-24 12:55:19
    赞同 1 展开评论 打赏
  • 哇塞女孩

    感谢分享感谢分享

    2022-08-24 12:52:12
    赞同 1 展开评论 打赏
  • 查查资料吧

    2022-08-24 12:50:32
    赞同 1 展开评论 打赏
  • 这个还真没遇到过

    2022-08-24 12:47:26
    赞同 1 展开评论 打赏
  • 你可以添加手动添加一个时间,然后利用这个手动添加的时间去做关联(此答案整理自Flink CDC 社区)

    2022-08-22 17:45:53
    赞同 1 展开评论 打赏
  • 就是Flink SQL还不支持呀。。。(此答案整理自Flink CDC 社区)

    2022-08-22 17:44:53
    赞同 1 展开评论 打赏
滑动查看更多

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
Lazy Join Optimizations Without Upfront Statistics 立即下载
Lambda Processing for Near Time Search Indexing 立即下载
Ream-time analytical query 立即下载