Flink Slot和Parallelism区别是什么?
发布时间:2022-09-02 16:59:28
发布人:wjy
Slot是指TaskManager的并发执行能力,如果代码运行前我们将slot的个数配置为3(taskmanager.numberOfTaskSlots) ,那么每个TaskManager会分配3个 Slot来执行task,如果配置了3个taskmanager 那么就如图一共有9个Slot。
Parallelism是指TaskManager在实际运行过程中的并发。默认并行度的配置为 1(parallelism.default),那么如图9个Slot只有一个是在工作的,其他8个都空闲。
在用户开发的过程中可以通过 setParallelism 方法给每个 Operators算子配置并行度。