已解决
flink选择slot
来自网友在路上 144844提问 提问时间：2023-10-02 01:44:21阅读次数： 44
最佳答案 问答题库448位专家为你答疑解惑
flink选择slot
在这个类里修改
package org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl;
findMatchingSlot(resourceProfile)：找到满足要求的slot（负责从哪个taskmanager中获取slot）对应上图第8，9，10部
allocateSlot(taskManagerSlot, pendingSlotRequest)：向resourcemanager注册，并将任务submit
该方法从freeslot中找到一个合适的slot，并将相应的taskmanagerSlot放入Optionl容器中，返回，之后注册，再将任务submit，
- freeslot中的15个槽，顺序是 (120：1) (120：2) (120：3) (120：4) (120：5）(121：1) (121：2) (121：3) (121：4) (121：5）(122：1) (122：2) (122：3) (122：4) (122：5） 默认是按顺序使用槽，但可以根据需要改
freeslotnums 用来记住使用了几个槽
查看全文
99%的人还看了
猜你感兴趣
版权申明
本文"flink选择slot"：http://eshow365.cn/6-15631-0.html 内容来自互联网，请自行判断内容的正确性。如有侵权请联系我们，立即删除！