I was going through the source code and it appears to me that there is a typo at
The line is highlighted below.
private[spark] class ZippedPartition[T: ClassManifest, U: ClassManifest](
idx: Int,
@transient rdd1: RDD[T],
@transient rdd2: RDD[U]
) extends Partition {
var split1 = rdd1.partitions(idx)
var split2 = rdd1.partitions(idx)
override val index: Int = idx
def splits = (split1, split2)
...