diff --git a/python/pyspark/context.py b/python/pyspark/context.py index efd942e4a23bf..5c98db235f3f8 100644 --- a/python/pyspark/context.py +++ b/python/pyspark/context.py @@ -383,7 +383,7 @@ def _getJavaStorageLevel(self, storageLevel): raise Exception("storageLevel must be of type pyspark.StorageLevel") newStorageLevel = self._jvm.org.apache.spark.storage.StorageLevel - return newStorageLevel(storageLevel.useDisk, storageLevel.useMemory, storageLevel.userTachyon, + return newStorageLevel(storageLevel.useDisk, storageLevel.useMemory, storageLevel.useTachyon, storageLevel.deserialized, storageLevel.replication) def setJobGroup(self, groupId, description):