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

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日

      悬赏问题

      • ¥50 R语言时间序列 滚动窗口预测
      • ¥15 Python不使用Selenium怎么实现网页输入和点击
      • ¥50 vue百度地图导致浏览器崩溃
      • ¥15 请问这段C语言代码应该如何修改呢
      • ¥20 Latex 转入带数式的曲线图后数式部分报错
      • ¥15 Arcgis基于一幅栅格提取另一幅栅格单元值
      • ¥15 Verilog数据产生器代码疑点
      • ¥15 电脑部分网页无法访问是为什么?
      • ¥15 如何在vscode导出pdf失败了,拓展也安装了?
      • ¥15 使用python-kivy如何点击按钮选择手机相册中的图片?