FlinkFlink做检查点checkpoint一直处于IN_PROGRESS状态

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink做检查点checkpoint一直处于IN_PROGRESS状态相关的知识,希望对你有一定的参考价值。

文章目录


1.概述

flink做checkpoint一直是IN_PROGRESS状态,查看java 堆栈信息展示错误


根据异常栈找到相应的代码requestMemorySegmentBlocking

 private MemorySegment requestMemorySegmentBlocking(int targetChannel)
            throws InterruptedException 
   
        

以上是关于FlinkFlink做检查点checkpoint一直处于IN_PROGRESS状态的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink 任务报错 Could not perform checkpoint for operator

FlinkFlink 反压机制 导致checkpoint 失败

FlinkFlink 不支持部分 task 结束后进行 checkpoint

FlinkFlink Exceeded checkpoint tolerable failure threshold

FlinkFlink 新一代流计算和容错 Unaligned Checkpoint快速Checkpoint更小的Checkpoint

FlinkFlink 记录一个 checkpoint 检查点 越来越大的问题