FlinkFlink 做检查点 报错 Checkpoint Coordinator is suspending.
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink 做检查点 报错 Checkpoint Coordinator is suspending.相关的知识,希望对你有一定的参考价值。
1.概述
flink任务做检查点的时候报错 Checkpoint Coordinator is suspending.
报错位置位于
/**
* 检查点协调器暂停
*/
CHECKPOINT_COORDINATOR_SUSPEND(false, "Checkpoint Coordinator is suspending."),
先看看处理方式,可以看到遇到这个报错直接忽略了
以上是关于FlinkFlink 做检查点 报错 Checkpoint Coordinator is suspending.的主要内容,如果未能解决你的问题,请参考以下文章
FlinkFlink 设置检查点失败一次就报错 setTolerableCheckpointFailureNumber 不起作用
FlinkFlink 报错 Corrupt data, magic number mismatch. Expected
Flinkflink 状态恢复 because the operator is not available in the new program
FlinkFlink做检查点checkpoint一直处于IN_PROGRESS状态