У меня высокодоступный кластер Flink с 3 узлами, на которых выполняются указанные ниже процессы.
1) StandaloneSessionClusterEntrypoint
2) TaskManagerRunner
3) FlinkZooKeeperQuorumPeer
Каждой машине назначается кучная память 10 ГБ (диспетчер задач) и 7 слотов.
Я запустил 11 заданий, и первые 7 заданий назначены текущему главному узлу, остальные 4 задания назначены второму узлу, а третий компьютер не назначен.
Причина:главному узлу не хватает памяти, а диспетчер задач вышел из строя в мастере (несколько заданий было удалено), поскольку задания не были правильно разделены для этих трех диспетчеров задач.
В чем может быть причина и как я могу это сделатьрешить эту проблему .?
Заранее спасибо.:)