Что такое SlotSharingGroup в Apache Flink? - PullRequest
0 голосов
/ 07 июня 2018

Ссылка: https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/runtime/jobmanager/scheduler/SlotSharingGroup.html

Определение: «Единицы совместного использования слотов определяют, какие разные задачи (из разных вершин заданий) могут быть развернуты вместе в одном слоте».

Может кто-нибудь уточнить это?больше?

1 Ответ

0 голосов
/ 11 июня 2018

Слот определяет фиксированный срез ресурсов TaskManager.Каждая подзадача (параллельный экземпляр оператора) нуждается в слоте для выполнения.

Поскольку не все операторы одинаково ресурсоемки, некоторым из них требуется больше циклов памяти или процессора, чем другим.Чтобы лучше использовать ресурсы, Flink позволяет развертывать подзадачи разных операторов в одном и том же слоте.

Какие операторы могут быть развернуты в одном и том же слоте, контролируется SlotSharingGroup.Задачи, которые совместно используют одну и ту же группу совместного использования слотов, могут выполняться в одном и том же слоте и, таким образом, совместно использовать ресурсы.По умолчанию всем операторам назначены одинаковые SlotSharingGroup.

Более подробную информацию о планировании работы Flink и внутренней архитектуре можно найти здесь и здесь .

...