Flink运行时可以转移数据吗?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink运行时可以转移数据吗?

Sun_yijia
有一个分支节点,分支后面有两个节点A和B。假设A节点出现了反压,B节点负载空闲。
我想让B节点帮A节点做一些计算,这样B节点就能够缓解一部分A节点的压力。


有什么方法能让Flink在运行过程中,把正常要发给A节点的数据发送给B节点吗?