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

flink多jobmanager运行重复输出问题

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

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

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

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

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

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

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

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

  • 写回答

1条回答 默认 最新

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

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

      悬赏问题

      • ¥15 ubuntu18.04 tty报错&tty界面su/sudo命令无法执行,如何解决?
      • ¥20 关于c语言网络编程,实现传文件和即时聊天
      • ¥20 下面的压缩方法是否可行
      • ¥15 结构体数组读取文件信息失败,读取不了
      • ¥15 kaldi thchs30 训练遇到问题
      • ¥15 shellter无法使用,如何解决?(操作系统-kali)
      • ¥15 matlab动态模态分解程序
      • ¥60 关于渗透及远控的几个问题
      • ¥15 python文本词汇出现次数统计
      • ¥15 使用按键和串口,记录按键在不消抖的情况下触发的次数