lpengdr...@163.com Wed, 01 Sep 2021 23:06:46 -0700
Hi: 请教下Flink的operator-chain的机制, 我看AsyncWaitOperator的chainingStrategy是ALWAYS,但是实际使用发现在所有算子并行度都设置为1的情况下这个operator没有办法和上游算子chain串起来只能跟下游的算子slot共享,这里边是还有什么其他规则吗?