Flink独立作业还原模式CLAIM

Flink的还原模式中，CLAIM是一种在启动时尝试恢复正在运行且失败的任务的机制。在独立作业模式下，可以使用以下代码示例将Flink作业改为还原模式：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000); // 开启检查点，设置检查点间隔时间为5秒
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); // 设置检查点模式为仅一次
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(500); // 设置两个检查点间的最小暂停时间
env.getCheckpointConfig().setCheckpointTimeout(60000); // 设置检查点超时时间为1分钟
env.getCheckpointConfig().setMaxConcurrentCheckpoints(1); // 设置最大并发检查点数为1
env.setStateBackend(new FsStateBackend("hdfs://localhost:9000/checkpoints")); // 设置状态后端
env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, Time.of(10, TimeUnit.SECONDS))); // 设置重启策略，最多重启3次，每次重启间隔10秒

在这个代码示例中，我们启用了5000毫秒的检查点，并将检查点模式设置为仅一次。我们还设置了两个检查点之间的最小暂停时间为500毫秒，并将检查点超时时间设置为1分钟。我们最大并发检查点数设置为1，并将状态后端设置为HDFS。最后，我们设置了一个重启策略，如果作业失败，它会在10秒后尝试重启，最多重启3次。

使用CLAIM模式启动Flink作业的代码示例如下：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000);
env.getCheckpointConfig().setCheckpointingMode(Checkpointing