Слот определяет фиксированный срез ресурсов TaskManager.Каждая подзадача (параллельный экземпляр оператора) нуждается в слоте для выполнения.
Поскольку не все операторы одинаково ресурсоемки, некоторым из них требуется больше циклов памяти или процессора, чем другим.Чтобы лучше использовать ресурсы, Flink позволяет развертывать подзадачи разных операторов в одном и том же слоте.
Какие операторы могут быть развернуты в одном и том же слоте, контролируется SlotSharingGroup
.Задачи, которые совместно используют одну и ту же группу совместного использования слотов, могут выполняться в одном и том же слоте и, таким образом, совместно использовать ресурсы.По умолчанию всем операторам назначены одинаковые SlotSharingGroup
.
Более подробную информацию о планировании работы Flink и внутренней архитектуре можно найти здесь и здесь .