什么是 Apache Flink 中的 SlotSharingGroup?



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

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

有人可以更详细地阐述它吗?

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

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

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

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

相关内容

  • 没有找到相关文章