From 00170eb0b9c30c1ab4f470c694b434385b8cbb7a Mon Sep 17 00:00:00 2001
From: Stephen Haberman <stephen@exigencecorp.com>
Date: Fri, 22 Mar 2013 12:59:08 -0500
Subject: [PATCH] Fix are/our typo.
---
core/src/main/scala/spark/RDD.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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)
--
GitLab