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

[jackjiang]

HI all，

由于checkpoint生成的
_metadata中存的hdfs路径是绝对路径，我目前想要迁移到另外一个集群中，想修改这个_metadata文件的数据，请问如何进行修改，有哪些可以参考的？

祝好

[Congxian Qiu]

你好

你可以按照 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
Best,
Congxian


蒋涛涛 <[hidden email]> 于2019年10月16日周三 下午7:20写道：

> HI all，
>
> 由于checkpoint生成的
>
> _metadata中存的hdfs路径是绝对路径，我目前想要迁移到另外一个集群中，想修改这个_metadata文件的数据，请问如何进行修改，有哪些可以参考的？
>
> 祝好
>