开发者社区 问答 正文

请问Flink的最大并行度跟kafka partition数量有关系吗? source的并行度应该最

请问Flink的最大并行度跟kafka partition数量有关系吗? source的并行度应该最好是跟partition数量一致吧,那剩下的算子并行度呢? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

展开
收起
黄一刀 2019-11-22 18:16:20 5769 分享
分享
版权
举报
2 条回答
写回答
取消 提交回答
  • 一般不是空跑,一般是多出来的那些task直接 finished了

    2019-11-22 21:23:14 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
  • 没有关系,如果flink的并发度大于kafka的partition那么就会有这sourceTask分配不到kafka的partiton,那个task就没有消费到数据,在空跑。

    2019-11-22 18:16:48 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等