没有了可用Task slot，Flink新增任务会怎样？

3 years ago

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新增任务会怎样？

原创

程序员欣宸 2022-07-19 23:33:36 博主文章分类：Java技能 ©著作权

文章标签 flink Java 文章分类 Java 编程语言 yyds干货盘点 阅读数198

欢迎访问我的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博客：程序员欣宸

学习路上，你不孤单，欣宸原创一路相伴…

</div

Recommend

www.cnblogs.com 4 years ago
Cache

IDEA上运行Flink任务

欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等； IDEA...

flink.apache.org 4 years ago
Cache

Apache Flink: Improvements in task scheduling for batch workloads in Apache Flin...

Improvements in task scheduling for batch workloads in Apache Flink 1.12 15 Dec 2020 Andrey Zagrebin The Flink community has been working for some time on making Flink a