云栖问答

找不到答案?去提问题

云栖社区 大数据 redis jvm 数据流 reduce source 2019-02-25 14:49:24

Flink 1.6.2版本稳定运行一段时间后为什么会出现flatMap层没有数据流入问题

Flink处理的数据量每秒大概有20条,每条数据最大50MB,在稳定运行一段时间后出现flatMap层没有数据流入问题,没出现任何报错,任务也没死掉

Source(kafka)-->flatMap-->reduce(聚合)-->sink(写入redis中)

kafka也没有问题,redis也正常,但是flatMap层就是不工作了,看到JVM的heap和TM的heap也都是正常的

求大佬指教

• 删除

0个回答

0
GO

看了该问题的人还看了