状态机转换
Finished:所有subtask FINISHED后,Job则进入状态。
Failing:
Failed:Failing状态时,subtask FAILED,作业不可重启,则进入此状态。
Suspended:除了3个终结状态都可以转为Suspended。
运行:Running
调度:Created
异常:其他全是异常。
所有subtask Canceled Job Canceled。
触发清理
Finished、Canceled、Failed表示全局终结,会触发清理。
Suspended,意味着JM终止,HA模式可以恢复,不会触发清理。
Slot分配
0x01
JM向RM申请Slot。
0x02
RM知道所有Slot情况,向TM调用TaskExecutor.requestSlot会精确到具体的SlotID。
0x03
TM向JM注册JobMasterGateway.registerTaskManager
。JobMasterGateway.offerSlots
将Free状态的Slot提供给JM。
0x04
JM向TMTaskManagerGateway.freeSlot(AllocationID),每个Slot都会调用一次。