slot个数与任务Stream的并行度相同即与任务中最大算子并行度相同,subtask个数为任务个数*并行度相加之和。
其中这个任务并行度为2,占用slot个数为2,subtask共4个。
假设TaskManager的slot个数为2,则上图并行子任务的分配如下
如下图,并行度为4,占用slot个数为4,其中AB为一个任务链中,共12个subtask
2023-11-09 10:38:52
slot个数与任务Stream的并行度相同即与任务中最大算子并行度相同,subtask个数为任务个数*并行度相加之和。
其中这个任务并行度为2,占用slot个数为2,subtask共4个。
假设TaskManager的slot个数为2,则上图并行子任务的分配如下
如下图,并行度为4,占用slot个数为4,其中AB为一个任务链中,共12个subtask