diff options
| -rw-r--r-- | python/pyspark/sql.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py index e7c35ac1ff..36e50e49c9 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): |