问题表象昨天，在给某flink任务添加一个自定义FlatMapFunction后，启动后看似任务正常，但未从kafka消费数据，10分钟之后，任务报错： org.apache.flink.runtime.JobException: Reco

2022-11-23 kill-the-bug