sinat_27054329 2022-04-24 10:13 采纳率: 66.7%
浏览 91
已结题

flink多jobmanager运行重复输出问题

代码逻辑就是很简单的wordcount,监听nc端口,输入单词计次数

本地测试逻辑没问题,但是跑在集群输出会重复

集群环境:(kubernetes部署,standalone-application模式)

问题:
多个jobmanager时候,输出也会多次
如: 3个jobmanager,nc输入一次hello,某个taskmanager日志输出:
hello,1
hello,2
hello,3

也就是几个jobmanager就计算了几次,然后输出几次

如果两个jobmanagr的时候就输出两次

并行度全局设置1,每个算子也单独设置1,同样的现象

哪位知道哪里的问题导致这样?

  • 写回答

1条回答 默认 最新

  • Juwell16 2022-04-24 10:24
    关注

    多个节点,同时获取到了数据,几个节点就有几次

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 5月9日
  • 已采纳回答 5月1日
  • 创建了问题 4月24日