TaskManager 架构.jpg
2.TaskManager 的组成模块
TaskManager 包含的模块有JobManager 模块、TaskSlot 管理、资源管理 ResourceManager、心跳检测 HeartbeatManager、存储服务 BlobCacheService。
2.1 TaskSlotTable
问题1： TaskSlot 的概念？
答：TaskSlot 任务槽是指运行 Task 的容器，与普通线程的最大区别是每个 Slot 都可以分配到独立的内存。
问题2：TaskSlot 的主要特点？
TaskSlot 具有内存管理、状态等能力，其主要特点是不同 JobVertex 可以共享 Slot。
![]()
image.png
TaskSlotTable 是管理 TaskSlot，其生命周期与 TaskManager 保持一致。TaskSlotTable 主要功能有添加和获取 Task、申请和释放 Slot。
2.2 JobLeaderService
JobLeaderService 用于监听 Master。如果 Master 节点改变，会通知 JobLeaderService，内部是以 jobId 为 key 保存 LeaderRetrievalService 和 JobManagerLeaderListener。
2.3 资源管理 ResourceManager
ResourceManager 用于监听 ResourceManager 主节点。如果主节点有变化，会通知 ResourceManagerLeaderRetriever。
2.4 心跳监测 HeartbeatManager
HeartbeatManager 模块包含 JobManagerHeartbeatManager 和 ResourceManagerHeartbeatManager 的心跳检测。
① JobManagerHeartbeatManager 负责检测 JobManager 与 TaskManager 的心跳；
② ResourceManagerHeartbeatManager 负责检测 ResourceManager 与 TaskManager 的心跳。
image.png
2.5 存储服务 BlobCacheService
BlobService 包含 PermanentBlobService 和 TransientBlobService。
① PermanentBlobService：可恢复，数据会上传到 BlobStore 分布式文件系统；
② TransientBlobService：不可恢复，数据不会上传到 BlobStore 分布式文件系统；
BLOB 底层存储，支持多种实现
HDFS,S3,FTP等，HA 中使用BlobStore 进行文件的恢复。
