微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Flink任务占用资源slot数与subtask个数

slot个数与任务Stream的并行度相同即与任务中最大算子并行度相同,subtask个数为任务个数*并行度相加之和。

在这里插入图片描述

其中这个任务并行度为2,占用slot个数为2,subtask共4个。
假设TaskManager的slot个数为2,则上图并行子任务的分配如下

在这里插入图片描述

如下图,并行度为4,占用slot个数为4,其中AB为一个任务链中,共12个subtask

在这里插入图片描述

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐