开发者社区 问答 正文

flink 本地main方法执行 window.aggregate 数据正常按key输出的多条,通过

flink 本地main方法执行 window.aggregate 数据正常按key输出的多条,通过jar包提交服务器执行为什么执行结果不正确,只能输出一条,有大神能帮忙分析下什么原因么? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

展开
收起
黄一刀 2019-11-18 11:44:42 1304 分享 版权
2 条回答
写回答
取消 提交回答
  • Java菜鸟一只,基层法律工作者。

    可以加点日志看看中间数据状态

    2019-11-18 13:50:56
    赞同 展开评论
  • flink理论上是不会出现这个问题的,可以先排查你数据来源、运行环境。

    2019-11-18 11:45:12
    赞同 展开评论