diff options
author | Matei Zaharia <matei@databricks.com> | 2013-12-29 00:11:36 -0500 |
---|---|---|
committer | Matei Zaharia <matei@databricks.com> | 2013-12-29 00:11:36 -0500 |
commit | 1c11f54a9b7340ccfa7bf7236fbcd210b77ae0a8 (patch) | |
tree | 17698638ba0c0414dd1ead6fd0f618d6b123647d /python/pyspark | |
parent | 20631348d198ba52059f278c1b415c3a80a95b81 (diff) | |
download | spark-1c11f54a9b7340ccfa7bf7236fbcd210b77ae0a8.tar.gz spark-1c11f54a9b7340ccfa7bf7236fbcd210b77ae0a8.tar.bz2 spark-1c11f54a9b7340ccfa7bf7236fbcd210b77ae0a8.zip |
Fix Python use of getLocalDir
Diffstat (limited to 'python/pyspark')
-rw-r--r-- | python/pyspark/context.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/context.py b/python/pyspark/context.py index 0604f6836c..c0645b2847 100644 --- a/python/pyspark/context.py +++ b/python/pyspark/context.py @@ -121,7 +121,7 @@ class SparkContext(object): self.addPyFile(path) # Create a temporary directory inside spark.local.dir: - local_dir = self._jvm.org.apache.spark.util.Utils.getLocalDir() + local_dir = self._jvm.org.apache.spark.util.Utils.getLocalDir(self._jsc.sc().conf()) self._temp_dir = \ self._jvm.org.apache.spark.util.Utils.createTempDir(local_dir).getAbsolutePath() |