slot个数与任务Stream的并行度相同即与任务中最大算子并行度相同,subtask个数为任务个数*并行度相加之和。
![在这里插入图片描述](https://www.icode9.com/i/ll/?i=f13464cde25e4902b89e85799d443074.png)
其中这个任务并行度为2,占用slot个数为2,subtask共4个。
假设TaskManager的slot个数为2,则上图并行子任务的分配如下
![在这里插入图片描述](https://www.icode9.com/i/ll/?i=b7637002802c4d9ea0fa12f60d5b4ea1.png?,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMTE4MDg2,size_16,color_FFFFFF,t_70)
如下图,并行度为4,占用slot个数为4,其中AB为一个任务链中,共12个subtask
![在这里插入图片描述](https://www.icode9.com/i/ll/?i=59605d3f3b6d488f906592e88278af20.png?,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMTE4MDg2,size_16,color_FFFFFF,t_70)
标签:slot,占用,Flink,个数,任务,并行度,subtask
来源: https://blog.csdn.net/qq_43118086/article/details/119139376