FlinkUI中的节点数量是由什么决定的?

来源:2-7 基于Flink开发第一个实时处理案例之需求分析

卜硕

2022-06-22

老师,下面两张图是我跑的两个job,我不太明白为啥一个job只有一个节点,另一个job会有两个节点,是什么样的操作会导致节点数量增加呀?
图片描述
图片描述

写回答

1回答

Michael_PK

2022-06-23

这涉及到flink task的切分

1)遇到shuffle算子会切     你的第二个图中使用看keyBy算子了吧  所以切了新的task

2)并行度发生变化会切

0
0

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据,Flink助力轻松提薪;尚未入行,让你弯道超车

1001 学习 · 225 问题

查看课程