开发者社区> 问答> 正文

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

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

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

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

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

    2019-11-18 11:45:12
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载