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

slot个数与任务Stream的并行度相同即与任务中最大算子并行度相同,subtask个数为任务个数*并行度相加之和。
Flink任务占用资源slot数与subtask个数
其中这个任务并行度为2,占用slot个数为2,subtask共4个。
假设TaskManager的slot个数为2,则上图并行子任务的分配如下

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

上一篇:第三届“图灵杯”趣味网络邀请赛(中级) 题解


下一篇:【*营业2】基于根号分治类Trick题