查看日志发现固定延迟重启策略似乎没有生效，我设置的是30s延迟重启2次， 但是日志显示的是在06:26:50这1秒内重启了2次都失败了，并最终导致任务失败， 我设置的延迟时间似乎完全没有生效，Flink版本是1.12.2。 有没有人能告诉我这是为什么?
日志的截图： [cid:image001.png@01D7F67C.D00DC560] [cid:image002.png@01D7F67C.D00DC560] 设置重启策略的代码： val env = StreamExecutionEnvironment.getExecutionEnvironment val backend = new FsStateBackend(CommonConfig.FLINK_STATEBACKEND_CHECKPOINT) env.setStateBackend(backend) // 每 30000ms 开始一次 checkpoint env.enableCheckpointing(30000) // 设置模式为精确一次 (这是默认值) env.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE) // 确认 checkpoints 之间的时间会进行 500 ms env.getCheckpointConfig.setMinPauseBetweenCheckpoints(10000) // Checkpoint 必须在2分钟内完成，否则就会被抛弃 env.getCheckpointConfig.setCheckpointTimeout(120000) // 可容忍checkpoint失败次数 env.getCheckpointConfig.setTolerableCheckpointFailureNumber(3) // 同一时间只允许一个 checkpoint 进行 env.getCheckpointConfig.setMaxConcurrentCheckpoints(1) //设置全局并行度 // env.setParallelism(3) //重启策略 //PS:默认策略会重启int最大值次，导致任务一直处于重启状态，checkpoint出现连续空文件夹，同时导致有效checkpoint无法使用 env.setRestartStrategy(RestartStrategies.fixedDelayRestart(2, Time.seconds(30)))
