开发者社区> 问答> 正文

已经运行的Flink任务修改代码重新启动会有什么影响

已解决

已经运行的Flink任务修改代码重新启动会有什么影响

展开
收起
提个问题 2024-05-24 13:08:48 20 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    停止任务时可以做一次savepoint快照,或者当任务有成功的checkpoint时可以选择直接停止任务。启动任务时可以选择对应的状态启动,这样数据会继续当时的位点开始读取,如果选择checkpoint恢复,checkpoint位点后有几分钟的数据会重复读取,就需要自己做代码去重处理,如果sink有主键的话 数据写入sink时会根据主键去重,就不会有影响。
    另外修改代码从状态恢复时,需要保证修改后代码的兼容性,判断方式可以参考SQL修改及兼容性
    2024-05-24 13:08:50
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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