diff options
author | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-22 12:59:08 -0500 |
---|---|---|
committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-22 12:59:08 -0500 |
commit | 00170eb0b9c30c1ab4f470c694b434385b8cbb7a (patch) | |
tree | e615609402da2c649be8d853ed436904a1ae0974 | |
parent | 1c67c7dfd1660dd39226742eedcb2948ab1445d0 (diff) | |
download | spark-00170eb0b9c30c1ab4f470c694b434385b8cbb7a.tar.gz spark-00170eb0b9c30c1ab4f470c694b434385b8cbb7a.tar.bz2 spark-00170eb0b9c30c1ab4f470c694b434385b8cbb7a.zip |
Fix are/our typo.
-rw-r--r-- | core/src/main/scala/spark/RDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala index 0cd904f89d..b88d711dcf 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) |