如何在多个数据中心上进行flink检查点/保存点备份

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.runtime.state.filesystem.FsStateBackend;
import org.apache.flink.runtime.state.CheckpointListener;
import org.apache.flink.streaming.api.CheckpointingMode;

public class MultiDCCheckpointExample {
    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 配置检查点
        env.enableCheckpointing(5000); // 每 5 秒进行一次检查点
        env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
        env.getCheckpointConfig().setMinPauseBetweenCheckpoints(1000);
        env.getCheckpointConfig().setCheckpointTimeout(60000);

        // 配置状态后端为文件系统，并指定多个数据中心的存储路径
        env.setStateBackend(new FsStateBackend("hdfs://dc1/checkpoints/,hdfs://dc2/checkpoints/"));

        // 添加检查点监听器（可选）
        env.getCheckpointConfig().enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);

        // 添加数据源和处理逻辑
        // ...

        env.execute("Multi-DC Checkpoint Example");
    }
}