diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py index e7c35ac1ffe025b2e61bd616ae8f306f8e8fdf1a..36e50e49c9a9c074d85577bb78ed874d80c0a317 100644 --- a/python/pyspark/sql.py +++ b/python/pyspark/sql.py @@ -1589,9 +1589,9 @@ class SchemaRDD(RDD): self._jschema_rdd.persist(javaStorageLevel) return self - def unpersist(self): + def unpersist(self, blocking=True): self.is_cached = False - self._jschema_rdd.unpersist() + self._jschema_rdd.unpersist(blocking) return self def checkpoint(self):