为什么所有作业 运行 都在单个任务管理器上?

Why all the jobs running on the single taskmanger?

我有一个独立的 flink 集群运行在一个节点上,有两个任务管理器。

我启动了35个作业后,发现所有的作业都运行在其中一个taskmanagers上。 另一个任务管理器上没有任务 运行。

我不知道出了什么问题。

参见https://issues.apache.org/jira/browse/FLINK-12122。我认为这个问题正在影响您的工作。您可以尝试升级到 Flink 1.9.2,或者在 flink-conf.yaml

中设置 cluster.evenly-spread-out-slots: true