You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/02 06:29:51 UTC
[13/33] git commit: Fix Python use of getLocalDir
Fix Python use of getLocalDir
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/1c11f54a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/1c11f54a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/1c11f54a
Branch: refs/heads/master
Commit: 1c11f54a9b7340ccfa7bf7236fbcd210b77ae0a8
Parents: 2063134
Author: Matei Zaharia <ma...@databricks.com>
Authored: Sun Dec 29 00:11:36 2013 -0500
Committer: Matei Zaharia <ma...@databricks.com>
Committed: Sun Dec 29 00:11:36 2013 -0500
----------------------------------------------------------------------
python/pyspark/context.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/1c11f54a/python/pyspark/context.py
----------------------------------------------------------------------
diff --git a/python/pyspark/context.py b/python/pyspark/context.py
index 0604f68..c0645b2 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()