Hi！ 截图无法在邮件中显示，可以使用外部图床上传，或直接把 log 的内容贴在邮件里。
Song PinRu <[email protected]> 于2021年12月21日周二 15:54写道： > 查看日志发现固定延迟重启策略似乎没有生效，我设置的是30s延迟重启2次， > > 但是日志显示的是在06:26:50这1秒内重启了2次都失败了，并最终导致任务失败， > > 我设置的延迟时间似乎完全没有生效，Flink版本是1.12.2。 > > 有没有人能告诉我这是为什么? > > > > 日志的截图： > > > > [image: cid:[email protected]] > > > > [image: cid:[email protected]] > > > > 设置重启策略的代码： > > 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))) > > >
