При использовании Flink 1.5 и 1.6, за исключением случаев, когда запущен устаревший режим (через mode: legacy
), распределение TaskManager с несколькими слотами поддерживается не полностью, и рекомендуется установить taskmanager.numberOfTaskSlots: 1
.Теперь, когда рефакторинг среды выполнения, известной как FLIP-6, завершен, это ограничение было снято.