13. 下-taskExecutor向RM注册自己的slot.png

TE注册自己的slot report

13.2. taskExecutor向Rm注册自己的slot信息

DONE:

1. TaskExecutor在接收到注册成功之后, 发布一个事件

2. 在TaskExecutor的registryListenr内向RM报告自己的slot: sendSlotReport

TODO

1. resourceManager什么时候向TM申请slot.

总的图看起来应该是:

接下来看什么

本来想接着按照黑图(来自高赟的flink进阶文章)的资源管理流程看下一步, RM如何向TM申请slot.

但是, 我没有找到该怎么办, taskExecutor发送了自己的slotReport之后, 我就断了联系了, 看不到其他的了.

所以, 就在高赟的文章里找到Flink的集群的基本结构的那张图, 看它第三步, client给dispatcher提交自己的jobGraph之后该怎么办.

我觉得JobExecutor起来之后肯定会到slot的申请啊什么的, 慢慢看, 只要有线索, 跟着就跑就得了, 多条线跟上一条就把别的解开了.

Flink的集群的基本结构