1
没有了可用Task slot，Flink新增任务会怎样？
source link: https://blog.51cto.com/zq2599/5487656
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
没有了可用Task slot，Flink新增任务会怎样？
原创欢迎访问我的GitHub
这里分类和汇总了欣宸的全部原创(含配套源码)： https://github.com/zq2599/blog_demos
没有了可用Task slot，新增任务会怎样？
-
如下图所示，一个普通Flink1.7的Local环境，正在运行一个并行度为4的任务，现有Task slot全部被使用，因此Available Task Slots为零：
-
如果这时候再提交一个任务，会出现什么情况呢？如下图，新提交的任务，状态是SCHEDULED（红框所示），执行的主机也没有分配（绿框所示）：
-
看来要想任务顺利执行，首先要保证slot数量够用，目前机器内存是够用的，那么就把slot数量调大些吧；
- 由于修改的配置文件要重启Flink才能生效，在生产环境请慎用！
- 根据官方文档的指导，应该修改conf目录下的flink-conf.yaml文件中taskmanager.numberOfTaskSlots的值，如下图红框所示，文档地址： https://ci.apache.org/projects/flink/flink-docs-master/ops/config.html
- 这里我将之前配置的4改为8（机器的CPU是四核，超线程开启），重启Flink；
- 重启Flink之后，再次提交两个任务，去看首页整体情况一切正常，如下图：
欢迎关注51CTO博客：程序员欣宸
- 赞
- 收藏
- 评论
- 分享
- 举报
Recommend
About Joyk
Aggregate valuable and interesting links.
Joyk means Joy of geeK