Apache Flink中的SlotSharingGroup是什么？ [英] What is SlotSharingGroup in Apache Flink?

问题描述

引用：https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/runtime/jobmanager/scheduler/SlotSharingGroup.html

定义："槽共享单元定义槽内可以一起部署哪些不同的任务(来自不同的作业顶点)。"

有人能详细说明一下吗？

推荐答案

槽定义任务管理器的固定资源切片。每个子任务(运算符的并行实例)都需要一个槽才能执行。

由于并非所有运算符都同样占用资源，因此其中一些运算符需要比其他运算符更多的内存或CPU周期。为了更好地利用资源，Flink允许将不同运营商的子任务部署到同一个槽中。

哪些运算符可以部署到同一个槽中由SlotSharingGroup控制。共享同一槽共享组的任务可以在同一槽中执行，从而共享资源。默认情况下，为所有运算符分配相同的SlotSharingGroup。

有关Flink计划和内部架构的详细信息，请参阅here和here。

这篇关于Apache Flink中的SlotSharingGroup是什么？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！