你好 你可以按照 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 蒋涛涛 <[email protected]> 于2019年10月16日周三 下午7:20写道： > HI all， > > 由于checkpoint生成的 > > _metadata中存的hdfs路径是绝对路径，我目前想要迁移到另外一个集群中，想修改这个_metadata文件的数据，请问如何进行修改，有哪些可以参考的？ > > 祝好 >
