可以阅读 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共享，这里边是还有什么其他规则吗？ > > >
