Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.0.0
-
None
Description
Otherwise, RDD.zip() would behave unexpectedly. For example, as given in SPARK-1817:
scala> sc.parallelize(1L to 2L,4).zip(sc.parallelize(11 to 12,4)).collect
res1: Array[(Long, Int)] = Array((2,11))
Attachments
Issue Links
- is depended upon by
-
SPARK-1817 RDD zip erroneous when partitions do not divide RDD count
- Resolved