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/context.py | |
| 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/context.py')
| -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() |