venn Fri, 11 Sep 2020 01:29:55 -0700
各位大佬,在执行flink 流任务的时候,经常会出现,某几台服务器的 CPU比较高(共 用集群,还有很多其他组件),导致在这些机器上的算子的延迟远远高于其他机器上的 算子,
请 flink 是否有动态分区策略或者 Taskmanager 迁移策略,可以完成类似于 spark 在算子执行很慢的情况下,master 会起一个一样的算子,如果后起的算子先完成任 务,任务也可见继续往下游执行。 感谢各位大佬