Flink 中资源管理的实现是什么过程

Flink 中的资源是由 TaskExecutor 上的 Slot 来表示的。在 ResourceManager 中，有个子组件叫做 SlotManager，它维护了当前集群中所有 TaskExecutor 上的 Slot 的信息与状态。当 JobManger 来为特定 Task 申请 资源的时候，根据当前是 Per-job 还是 Session 模式，ResourceManager 可能会去申请资源来启动新的 TaskExecutor。当 TaskExecutor 启动之后，它会通过服务发现找到当前活跃的 ResourceManager 并进行注册。在注册信息中，会包含该 TaskExecutor 中所有 Slot 的信息。 ResourceManager 收到注册信息后，其中 的 SlotManager 就会记录下相应的 Slot 信息。