FlinkUI中的节点数量是由什么决定的?
来源:2-7 基于Flink开发第一个实时处理案例之需求分析

卜硕
2022-06-22
老师,下面两张图是我跑的两个job,我不太明白为啥一个job只有一个节点,另一个job会有两个节点,是什么样的操作会导致节点数量增加呀?
写回答
1回答
-
Michael_PK
2022-06-23
这涉及到flink task的切分
1)遇到shuffle算子会切 你的第二个图中使用看keyBy算子了吧 所以切了新的task
2)并行度发生变化会切
00
相似问题