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的申请啊什么的, 慢慢看, 只要有线索, 跟着就跑就得了, 多条线跟上一条就把别的解开了.
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。