FLinkFLink 消费 kafka 报错 Selector Close Connection Null NetworkReceive OOM 内存溢出
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FLinkFLink 消费 kafka 报错 Selector Close Connection Null NetworkReceive OOM 内存溢出相关的知识，希望对你有一定的参考价值。
文章目录
1.概述
一套代码写了有半年了，目前在十几个集群运行，然后一直没有问题，今天突然有一个环境，不消费数据了。
然后查看健康，发现kafka的source 节点不读取数据了。
然后看日志有如下报错
查看kafka是正常的，其他流也正常，
以上是关于FLinkFLink 消费 kafka 报错 Selector Close Connection Null NetworkReceive OOM 内存溢出的主要内容，如果未能解决你的问题，请参考以下文章
FlinkFlink1.12.0 FlinkSQL消费Kafka 使用 temporal join 关联维表Hive 最新分区数据 join 不上
FLinkFlink 消费 kafka 消费组 死掉 Marking the coordinator dead for group 造成数据重复消费
FlinkFlink 消费 kafka 实现 限流处理 RateLimiter
FlinkFlink kerberos 认证报错 while accessing user/group information via Hadoop utils