开发者社区> 问答> 正文

flink版本升级问题咨询

目前现状:公司flink任务都是跑在flin1.7当中,通过公司开发的流计算平台进行提交到flink yarn集群,flink on yarn 基于flink session进行部署,运行任务有接近500个流式任务,许多都是有状态应用,现在如果想把flink集群升级到1.11或者1.12,如何平滑的进行版本升级,而不影响现有的任务?*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-08 12:08:07 609 0
1 条回答
写回答
取消 提交回答
  • 我试过 flink 1.7 升级到 1.10。如果使用到了 table api 涉及 group By 的话 savePoint恢复有问题,其他没发现过什么问题。或者可以使用下 process api 写一份数据,启动 job*来自志愿者整理的flink邮件归档

    2021-12-08 16:09:49
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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