开发者社区> 问答> 正文

flink1.9状态及作业迁移

flink1.9的检查点或保存点中会保留hadoop集群的nameservice数据吗?现在想将一个集群的flink作业迁移到另一个集群,但两个集群的nameservice名称不一样,迁移会有问题吗?如果有问题的话对应状态保存的nameservice可以修改吗?或者说迁移的时候还有哪些其他需要注意的问题?

*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-07 15:40:17 757 0
1 条回答
写回答
取消 提交回答
  • Checkpoint meta中存储的是完整路径,所以一般会把hdfs的namespace存储起来,导致没办法直接迁移。

    Flink-1.11 支持将savepoint(但是不支持Checkpoint)进行位置迁移 [1],而对于Flink-1.9,二者均不支持。

    [1] https://issues.apache.org/jira/browse/FLINK-5763*来自志愿者整理的flink邮件归档

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

相关电子书

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