如果自己实现 KeySelector ，可以感知 下游节点的反压，动态调整 KeySelector 策 略 就可以
-----Original Message----- From: user-zh-return-6979-wxchunjhyy=163....@flink.apache.org <user-zh-return-6979-wxchunjhyy=163....@flink.apache.org> On Behalf Of Sun_yijia Sent: Wednesday, August 26, 2020 2:17 PM To: user-zh <user-zh@flink.apache.org> Subject: Flink运行时可以转移数据吗？ 在做反压相关的代码，想请教各位大佬。 有一个分支节点，分支后面有两个节点A和B。假设A节点出现了反压，B节点负载空闲。 我想让B节点帮A节点做一些计算，这样B节点就能够缓解一部分A节点的压力。 有什么方法能让Flink在运行过程中，把接下来要发给A节点的数据发送给B节点吗？
