开发者社区> 问答> 正文

Flink SQL JDBC connector不能checkpoint怎么办

Flink开发者们,你们好:

我在使用flink开发过程中遇到一个问题,在使用jdbc做维度表关联时,该算子很快就finished了,从而导致无法正常的checkoint(我看源码中checkpoint前会检查所有算子状态必须为running),请问目前有什么参数可以使jdbc不finished或者在算子finished后依然可以checkpoint么?如果没有,那对这种情况的支持是否列入flink未来版本的开发计划中?

期待你们的回信

祝各位工作顺利,谢谢*来自志愿者整理的flink邮件归档

展开
收起
moonlightdisco 2021-12-01 11:49:58 1033 0
1 条回答
写回答
取消 提交回答
  • hi, 请问使用的Flink版本是什么呢?猜测你应该是写成普通的join方式了,可参考 [1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sql/queries.html#joins*来自志愿者整理的flink邮件归档

    2021-12-01 14:11:16
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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