Flink распределяет задачи одному диспетчеру, пока слоты не заполнятся

Question

У меня кластер Flink с 5 узлами. И у каждого узла есть 8 слотов. Я использую Flink 1.5.2.

Если заданий N, проблема в том, что:

Если N <= 8, все задачи будут назначены на узел 1. Новые задачи будут назначены на узел 2, пока он не будет заполнен. А остальные узлы будут пустыми. </p>

Я хочу, чтобы все задачи были распределены по всем узлам. Кто-нибудь может помочь?

Спасибо.

Answer 1

Планировщик менеджера заданий не знает, к каким менеджерам задач принадлежат слоты, поэтому нет возможности сбалансировать распределение задач.