Preserve partitioner in retag().

apache · Jul 30, 2014 · 469d941 · 469d941
1 parent af78816
commit 469d941
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala
@@ -1258,6 +1258,7 @@ abstract class RDD[T: ClassTag](
       override protected def getPartitions: Array[Partition] = oldRDD.getPartitions
       override def compute(split: Partition, context: TaskContext): Iterator[T] =
         oldRDD.compute(split, context)
+      @transient override val partitioner = oldRDD.partitioner
     }
   }