开发者社区 问答 正文

Flink OperatorChain AsyncWaitOperator

请教下Flink的operator-chain的机制, 我看AsyncWaitOperator的chainingStrategy是ALWAYS,但是实际使用发现在所有算子并行度都设置为1的情况下这个operator没有办法和上游算子chain串起来只能跟下游的算子slot共享,这里边是还有什么其他规则吗?*来自志愿者整理的flink邮件归档

展开
收起
moonlightdisco 2021-12-02 17:15:36 703 分享 版权
1 条回答
写回答
取消 提交回答
  • 可以阅读 StreamingJobGraphGenerator.isChainable()方法来详细了解chain的规则,具体到AsyncWaitOperator,应该与FLINK-13063 有关*来自志愿者整理的FLINK邮件归档

    2021-12-02 17:45:33
    赞同 展开评论