天天看点

95-280-035-源码-资源管理-计算资源管理-TaskSlot2.概述3. Task Slot 的基本概念

95-280-035-源码-资源管理-计算资源管理-TaskSlot2.概述3. Task Slot 的基本概念

2.概述

在 Flink 中,计算资源的是以 Slot 作为基本单位进行分配的。本文将对 Flink 中计算资源的管理机制加以分析。

3. Task Slot 的基本概念

​ 我们在前面的文章中了解了 Flink 集群的启动流程。在 Flink 集群中,每个 TaskManager 都是一个单独的 JVM 进程(非 MiniCluster 模式),并且在一个 TaskManager 中可能运行多个子任务,这些子任务都在各自独立的线程中运行。为了控制一个 TaskManager 中可以运行的任务的数量,引入了 Task Slot 的概念。

看这个图,假设一个流任务是这样的

95-280-035-源码-资源管理-计算资源管理-TaskSlot2.概述3. Task Slot 的基本概念

然后对应的槽位可能是这样的

继续阅读