我有一个独立的flink集群运行在一个节点上，有两个taskmanager。在我开始了35个工作之后，我发现所有的工作都在一个TaskManager上运行。没有任务在其他taskmanger上运行。我不知道出了什么问题。
vsnjm48y1#
看到了吗https://issues.apache.org/jira/browse/flink-12122. 我认为这个问题正在影响你的工作。您可以尝试升级到flink 1.9.2或设置 cluster.evenly-spread-out-slots: true 在 flink-conf.yaml
cluster.evenly-spread-out-slots: true
flink-conf.yaml
1条答案
按热度按时间vsnjm48y1#
看到了吗https://issues.apache.org/jira/browse/flink-12122. 我认为这个问题正在影响你的工作。您可以尝试升级到flink 1.9.2或设置
cluster.evenly-spread-out-slots: true在flink-conf.yaml