Flink 能形成算子链的条件

两个 operator chain 在一起的的条件：
上下游的并行度一致
下游节点的入度为 1 （也就是说下游节点没有来自其他节点的输入）
上下游节点都在同一个 slot group 中(Slot槽位共享)
下游节点的 chain 策略为 ALWAYS（可以与上下游链接，map、flatmap、filter 等默认 是 ALWAYS）
上游节点的 chain 策略为 ALWAYS 或 HEAD（只能与下游链接，不能与上游链接， Source 默认是 HEAD）
两个节点间数据分区方式是 forward
用户没有禁用chain