【Flink】FlinkExceededcheckpointtolerablefailurethreshold

1.概述

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

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

2.源码

2.1 源码解析

对应的源码位置位于

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