FlinkFlink 不支持部分 task 结束后进行 checkpoint
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink 不支持部分 task 结束后进行 checkpoint相关的知识,希望对你有一定的参考价值。
纪念一波,九师兄博客热门订阅专栏时常名列前茅,我飘了,哈哈哈哈,得意的笑
1.概述
以前遇到一个问题,这个问题是这样的,一个FLink job,然后部分是离线任务,数据读取完毕了,就结束了。然后发现就不做检查点了,当时没想明白,然后找到了一个老版本才出出现这样的问题。
参考:【Flink】Flink 部分算子是 FinishSHED 不做checnpoint
然后今天在一个博客中发现了原因,参考:面向流批一体的 Flink Runtime 新进展
在流模式下支持部分 task 结束后继续做
以上是关于FlinkFlink 不支持部分 task 结束后进行 checkpoint的主要内容,如果未能解决你的问题,请参考以下文章
FlinkFlink 报错 An OperatorEvent from an OperatorCoordinator to a task was lost
flinkFlink 1.12.2 源码浅析 : Task数据输入
FlinkFlink Not all required tasks are currently running 未解决
flinkFlink 1.12.2 源码浅析 :Task数据输出
FlinkFLink Task did not exit gracefully within 180 + seconds 未解决