任务槽 task slots

slot共享

并行度:算子的子任务个数

程序的并行度:最大算子并行度

假设:

设置全局并行度为6,保持sink为1

source,map(6) -》keyby。。。(6) -》sink(1)

总共有13个子任务

2 个taskmanger , 每个taskmanger 3个slot

Author

Lavine Hu

Posted on

2022-04-25

Updated on

2022-04-25

Licensed under

Comments

:D 一言句子获取中...