Skip to content

Commit 59577df

Browse files
committed
SPARK-1770: Revert accidental(?) fix
Looks like this change was accidentally committed here: apache@06b15ba but the change does not show up in the PR itself (apache#704). Other than not intending to go in with that PR, this also broke the test JavaAPISuite.repartition. Author: Aaron Davidson <[email protected]> Closes apache#716 from aarondav/shufflerand and squashes the following commits: b1cf70b [Aaron Davidson] SPARK-1770: Revert accidental(?) fix
1 parent bd67551 commit 59577df

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)