FlinkFlink Exceeded checkpoint tolerable failure threshold

Posted 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink Exceeded checkpoint tolerable failure threshold相关的知识，希望对你有一定的参考价值。

文章目录


1.概述

Flink程序，如果单平行度运行是正常的，多并行度运行时有一个subtask的数据量很少，写kafka的数据为0，在做checkpoint的时候就会超时。报错如图


这个错误的意思是：超过检查点可容忍失败阈值

对应的源码位置位于

   /**
     * 超过检查点可容忍失败阈值
     */
    public static final String EXCEEDED_CHECKPOINT_TOLERABLE_FAILURE_MESSAGE =

以上是关于FlinkFlink Exceeded checkpoint tolerable failure threshold的主要内容，如果未能解决你的问题，请参考以下文章

FlinkFlink 1.13 编译 报错 The following files had format violations -Dspotless.check.skip=true

FlinkFlink 1.13 编译 报错 The following files had format violations -Dspotless.check.skip=true

context deadline exceeded

Go Bigquery 上的 DEADLINE_EXCEEDED

BigQuery 插入请求的 DEADLINE_EXCEEDED 异常

解决关于 npm build --prod ，出现 ERROR in budgets, maximum exceeded for initial. Budget 5 MB was exceeded b