为什么所有作业 运行 都在单个任务管理器上?
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
我有一个独立的 flink 集群运行在一个节点上,有两个任务管理器。
我启动了35个作业后,发现所有的作业都运行在其中一个taskmanagers上。 另一个任务管理器上没有任务 运行。
我不知道出了什么问题。
参见https://issues.apache.org/jira/browse/FLINK-12122。我认为这个问题正在影响您的工作。您可以尝试升级到 Flink 1.9.2,或者在 flink-conf.yaml
cluster.evenly-spread-out-slots: true