Apache Flink 中的 SlotSharingGroup 是什么？

Question

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

定义：“一个槽共享单元定义了可以在一个槽内一起部署哪些不同的任务（来自不同的工作顶点）。”

有人可以详细说明一下吗？

Answer 1

插槽定义了 TaskManager 的固定资源切片。每个子任务（算子的并行实例）都需要一个槽才能执行。

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

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

更多关于 Flink 的调度和内部架构的信息可以在这里和这里找到。