diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 97c70d5c01ce4..881520645535b 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -257,7 +257,7 @@ def materialize(self): """ Action to force materialization of this RDD. Returns a new RDD. """ - return RDD(self._jrdd.materialize(), self.ctx, + return RDD(self._jrdd.rdd().materialize(), self.ctx, self._jrdd_deserializer) def checkpoint(self):