FixedDelay

2024/4/28 7:35:35

Flink / Kafka 异常 - 6.Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy 排查与修复

一.引言 使用 Flink - Kafka 接数据 Source 时程序报错: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy 任务每次启动后持续10min左右,然后 RUNNING -> FAILED,如此重启失败了多次。 二.问题现象 1.任务 …