Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy
时间: 2024-01-06 07:44:20 浏览: 27
在Flink中,Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(在FixedDelayRestartBackoffTimeStrategy策略下,恢复被抑制)是一种应用于作业故障恢复的策略。当作业失败后,Flink会根据该策略来确定是否立即尝试重启作业,或者等待一段时间后再尝试重启。
具体来说,FixedDelayRestartBackoffTimeStrategy会根据预定义的固定重试延迟时间间隔,在每次作业失败后等待指定的时间,然后再尝试重新启动作业。这个策略的目的是为了避免频繁地重启作业,以免对系统造成额外的压力。
根据您提供的引用内容,可能是作业在运行一段时间后出现问题,然后报错并挂掉。其中一个报错信息是"Checkpoint Coordinator is suspending"(检查点协调器正在挂起)。这可能意味着检查点机制出现了问题,导致作业无法正常进行检查点操作。
另一个引用内容提到,在黑盒测试中,将BATCH_ROLLOVER_INTERVAL(定时生成新文件的策略,根据文件大小)设置为一分钟时,作业没有问题,并持续运行了3天。INACTIVE_BUCKET_THRESHOLD(未响应等待时长)也被修改了。
综上所述,与Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy相关的内容可能暗示着作业的恢复机制出现了问题,而且可能与检查点机制有关。可以进一步检查检查点配置、作业日志以及相关的错误信息来确定具体的原因和解决方案。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [Flink写入hdfs报错:Flink job failed with “Checkpoint Coordinator is suspending](https://blog.csdn.net/qq_37334150/article/details/113397031)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]