shuffle并行度的疑问
text.map(num => num) .setParallelism(2) //设置map算子的并行度为2 .shuffle .print() .setParallelism(4) //设置print算子的并行度为4 老师这是你StreamPartitionOpScala里面的代码，为什么在shuffle之前还要在设置一下并行度啊？不是值验证shuffle的随机性吗
3
收起
正在回答 回答被采纳积分+1
相似问题
map算子并行度和print算子并行度问题
6
0
3
关于shuffle疑问
14
0
5
padding-bottom控制高度有疑问，另图片显示有问题
47
0
12
shuffle
1
0
3
老师，map阶段从shuffle中读取数据？
4
0
1
登录后可查看更多问答，登录/注册
恭喜解决一个难题，获得1积分~
来为老师/同学的回答评分吧
0 星