FlinkFlink 任务报错 Could not perform checkpoint for operator

Posted 2022-12-15 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink 任务报错 Could not perform checkpoint for operator相关的知识，希望对你有一定的参考价值。

1.概述

一个Flink 做检查点的时候报错 `Could not perform checkpoint for operator` 详情如下

报错原因：检查点没保存，反压了

2. 源码解读

在节点收到Barrier的时候做检查点，在执行performCheckpoint的时候报错

以上是关于FlinkFlink 任务报错 Could not perform checkpoint for operator的主要内容，如果未能解决你的问题，请参考以下文章

FlinkFlink 提交任务报错 File does not exit /tmp/application_xxx-flink-conf.yml

FlinkFlink 运行报错 does not have any open files

Spring可执行定时任务的线程池ThreadPoolTaskScheduler报错：required a bean of type that could not be found.

FlinkFlink 报错 Initial AbstractPagedOutputView Segment may not be null

FlinkFLink 使用 RocksDB 报错 hadoop not have enough number of replicas

FlinkFLink 使用 RocksDB 报错 hadoop not have enough number of replicas