We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9916202 commit db6cb30Copy full SHA for db6cb30
core/src/main/scala/org/apache/spark/rdd/SlidingRDD.scala
@@ -84,7 +84,7 @@ class SlidingRDD[T: ClassTag](@transient val parent: RDD[T], val windowSize: Int
84
tail ++= nextHeads(j)
85
j += 1
86
}
87
- partitions += new SlidingRDDPartition[T](partitionIndex, parentPartitions(i), tail.toSeq)
+ partitions += new SlidingRDDPartition[T](partitionIndex, parentPartitions(i), tail)
88
partitionIndex += 1
89
// Skip appended heads.
90
i = j
0 commit comments