可以阅读 StreamingJobGraphGenerator.isChainable()方法来详细了解chain的规则,具体到AsyncWaitOperator,应该与FLINK-13063 有关
在 2021-09-02 14:05:52,"lpengdr...@163.com" <lpengdr...@163.com> 写道: >Hi: > >请教下Flink的operator-chain的机制, >我看AsyncWaitOperator的chainingStrategy是ALWAYS,但是实际使用发现在所有算子并行度都设置为1的情况下这个operator没有办法和上游算子chain串起来只能跟下游的算子slot共享,这里边是还有什么其他规则吗? > > >