开发者社区> 问答> 正文

如何修改checkpoint生成的_metadata文件中的hdfs路径?

由于checkpoint生成的 _metadata中存的hdfs路径是绝对路径,我目前想要迁移到另外一个集群中,想修改这个_metadata文件的数据,请问如何进行修改,有哪些可以参考的?*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-08 10:13:11 859 0
1 条回答
写回答
取消 提交回答
  • 你可以按照 checkpoint 的生成规则,从原来的 checkpoint 恢复回来,然后尝试把里面所有的地址修改一下,可以参考 CheckpointCoordinator#restoreSavepoint 的逻辑[1]

    [1] https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1119*来自志愿者整理的flink邮件归档

    2021-12-08 10:45:19
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
海量数据分布式存储——Apache HDFS之最新进展 立即下载
HDFS on Kubernetes--Lessons Le 立即下载
What’s new in Hadoop Common and HDFS 立即下载