FlinkFlink 报错 An OperatorEvent from an OperatorCoordinator to a task was lost
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink 报错 An OperatorEvent from an OperatorCoordinator to a task was lost相关的知识，希望对你有一定的参考价值。
文章目录
1.概述
Flink 报错 An OperatorEvent from an OperatorCoordinator to a task was lost 这个异常出现时候，就不能正常采集数据了，该如何处理
重启之后就是chunks,然后就ckeckpoint，但不采集数据了
2.源码分析
根据报错找到报错的位置
class SubtaskGatewayImpl implements OperatorCoordinator.SubtaskGateway<以上是关于FlinkFlink 报错 An OperatorEvent from an OperatorCoordinator to a task was lost的主要内容，如果未能解决你的问题，请参考以下文章
Flinkflink 状态恢复 because the operator is not available in the new program
FlinkFlink Unable to commit transaction an invalid state aborted for some reasone
Flinkflink Operator State 的使用及Redistribute listState UnionListState
FlinkFlink 报错 Writing records to streamload failed
FlinkFlink 写入 kafka 报错 Transactional Id authorization failed