diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala index 0cd904f89d8a28946aaed824c3a1e0e7db93906f..b88d711dcfe2bb648dc0006e64efdb26b9463905 100644 --- a/core/src/main/scala/spark/RDD.scala +++ b/core/src/main/scala/spark/RDD.scala @@ -240,7 +240,7 @@ abstract class RDD[T: ClassManifest]( */ def coalesce(numPartitions: Int, shuffle: Boolean = false): RDD[T] = { if (shuffle) { - // include a shuffle step so that are upstream tasks are still distributed + // include a shuffle step so that our upstream tasks are still distributed new CoalescedRDD(new ShuffledRDD(map(x => (x, null)), new HashPartitioner(numPartitions)), numPartitions).keys } else { new CoalescedRDD(this, numPartitions)