开发者社区> 问答> 正文

flink sql join 可以有 state 存储并从 state 恢复数据吗?

有两个表: 

tableA: key valueA 

tableB: key valueB 

我之前用 flink state 的方式存储 tableA,tableB 的消息过来以后去 query 这个 state 得到 valueA 

直接 写 flinkSQL 也可以实现这种功能,但这两个表有时间差,任务停止后重新提交会丢失部分 join 的结果。 

flinkSQL 有没有类似 flink cancel -s 保存 state 的功能呢?*来自志愿者整理的flink邮件归档

展开
收起
玛丽莲梦嘉 2021-12-02 16:23:57 731 0
1 条回答
写回答
取消 提交回答
  • 确实是可以 直接 flink cancel -s 保存状态。 

    但我是用 flink-sql-client 直接写 sql 提交的 job,再提交的时候怎样可以指定状态目录让这个任务从状态恢复呢?*来自志愿者整理的FLINK邮件归档

    2021-12-02 17:20:12
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载