Spark repartition VS coalesce

Spark repartition VS coalesce demo val data=sc.parallelize(Array("a","b","c","d","e","a","b","e","b","f"),2) scala> data.glom().collect() res1: Array[Array[String]] = Array(Array(a, b, c, d, e), Arra

>>阅读原文<<