Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
flink 动态分区策略
Classic
List
Threaded
♦
♦
Locked
1 message
venn
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
flink 动态分区策略
各位大佬,在执行flink 流任务的时候,经常会出现,某几台服务器的 CPU比较高(共
用集群,还有很多其他组件),导致在这些机器上的算子的延迟远远高于其他机器上的
算子,
请 flink 是否有动态分区策略或者 Taskmanager 迁移策略,可以完成类似于 spark
在算子执行很慢的情况下,master 会起一个一样的算子,如果后起的算子先完成任
务,任务也可见继续往下游执行。
感谢各位大佬
Free forum by Nabble
Edit this page