Hi 据我所知,在作业启动之后,是无法改变数据的分法规则的,也就是说没办法做到这个要求。 Best, Congxian
Sun_yijia <[email protected]> 于2020年8月26日周三 下午2:17写道: > 在做反压相关的代码,想请教各位大佬。 > > > 有一个分支节点,分支后面有两个节点A和B。假设A节点出现了反压,B节点负载空闲。 > 我想让B节点帮A节点做一些计算,这样B节点就能够缓解一部分A节点的压力。 > > > 有什么方法能让Flink在运行过程中,把接下来要发给A节点的数据发送给B节点吗?
