shuffle并行度的疑问
1 2 3 4 5 6 7 8 | 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
shuffle
1
0
3
padding-bottom控制高度有疑问，另图片显示有问题
47
0
12
一些关于调度的疑问
39
1
9
登录后可查看更多问答，登录/注册
恭喜解决一个难题，获得1积分~
来为老师/同学的回答评分吧