admin管理员组

文章数量:1619183

文章目录

  • 1.概述
  • 2.源码
    • 2.1 源码解析
    • 2.2 小结
  • 3.场景2

1.概述

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


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

2.源码

该部分的头一段源码分析在这里:【Flink】Flink 设置检查点失败一次就报错 setTolerableCheckpointFailureNumber 不起作用

2.1 源码解析

对应的源码位置位于

   /**
     * 超过检查点可容忍失败阈值
     */

本文标签: CheckPointexceededFlinkthresholdfailure