Skip to content

Commit c10e8c7

Browse files
committed
Merge branch 'master' of github.com:apache/spark into yarn-docs
2 parents 381fe32 + 59577df commit c10e8c7

File tree

1 file changed

+2
-2
lines changed
  • core/src/main/scala/org/apache/spark/rdd

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/rdd/RDD.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -330,9 +330,9 @@ abstract class RDD[T: ClassTag](
330330
if (shuffle) {
331331
// include a shuffle step so that our upstream tasks are still distributed
332332
new CoalescedRDD(
333-
new ShuffledRDD[Int, T, (Int, T)](map(x => (Utils.random.nextInt(), x)),
333+
new ShuffledRDD[T, Null, (T, Null)](map(x => (x, null)),
334334
new HashPartitioner(numPartitions)),
335-
numPartitions).values
335+
numPartitions).keys
336336
} else {
337337
new CoalescedRDD(this, numPartitions)
338338
}

0 commit comments

Comments
 (0)