Skip to content
Snippets Groups Projects
Commit 00170eb0 authored by Stephen Haberman's avatar Stephen Haberman
Browse files

Fix are/our typo.

parent 1c67c7df
No related branches found
No related tags found
Loading
......@@ -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)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment