flink自定义检查点存储位置

Flink 的 Checkpoint 默认是存储在 JobManager 的内存中的，也可以配置为存储在文件系统中。如果需要自定义 Checkpoint 存储位置，可以通过在 flink-conf.yaml 文件中添加如下配置：

state.checkpoints.dir: hdfs://<hdfs-host>:<hdfs-port>/<checkpoint-dir>

其中，`<hdfs-host>` 和 `<hdfs-port>` 分别是 HDFS 的地址和端口号，`<checkpoint-dir>` 是 Checkpoint 存储的目录名。

另外，也可以在代码中通过调用 `env.setStateBackend()` 和 `env.enableCheckpointing()` 方法来设置 Checkpoint 存储位置。例如：

String checkpointDir = "hdfs://<hdfs-host>:<hdfs-port>/<checkpoint-dir>";
StateBackend stateBackend = new FsStateBackend(checkpointDir, true);
env.setStateBackend(stateBackend);
env.enableCheckpointing(5000);

这里使用 `FsStateBackend` 将 Checkpoint 存储在 HDFS 中，`enableCheckpointing()` 方法的参数表示每隔 5000 毫秒执行一次 Checkpoint。