文章目录

1.概述
一套代码写了有半年了,目前在十几个集群运行,然后一直没有问题,今天突然有一个环境,不消费数据了。
然后查看健康,发现kafka的source 节点不读取数据了。
然后看日志有如下报错
查看kafka是正常的,其他流也正常,
【FLink】FLink 消费 kafka 报错 Selector Close Connection Null NetworkReceive OOM 内存溢出
阅读 70
2022-03-12
一套代码写了有半年了,目前在十几个集群运行,然后一直没有问题,今天突然有一个环境,不消费数据了。
然后查看健康,发现kafka的source 节点不读取数据了。
然后看日志有如下报错
查看kafka是正常的,其他流也正常,
相关推荐
精彩评论(0)