状态机转换

image.png
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.registerTaskManagerJobMasterGateway.offerSlots将Free状态的Slot提供给JM。
0x04
JM向TMTaskManagerGateway.freeSlot(AllocationID),每个Slot都会调用一次。