修改分区就行了
val rdd1 = sc.parallelize(Array(1,2,3,4,5,6,7,8))
# 查看分区数
rdd1.partitions.length
# 改成1个分区
val rdd2 = rdd1.repartition(1)
rdd2.partitions.length
相关文章：
相似解决方案
热门标签
修改分区就行了
val rdd1 = sc.parallelize(Array(1,2,3,4,5,6,7,8))
# 查看分区数
rdd1.partitions.length
# 改成1个分区
val rdd2 = rdd1.repartition(1)
rdd2.partitions.length
相关文章：