diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-17 17:00:25 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-17 17:00:25 -0800 |
| commit | b534fd363fc0db05910c5a144fcfba2d6f228f93 (patch) | |
| tree | a29b0a4d5ed6a6697e32eb8f9f36396c0aa5d783 | |
| parent | 46644e409de2b12b83c5954128c718a27d00982b (diff) | |
| parent | 742bc841adb2a57b05e7a155681a162ab9dfa2c1 (diff) | |
| download | spark-b534fd363fc0db05910c5a144fcfba2d6f228f93.tar.gz spark-b534fd363fc0db05910c5a144fcfba2d6f228f93.tar.bz2 spark-b534fd363fc0db05910c5a144fcfba2d6f228f93.zip | |
Merge pull request #382 from fanuo/master
HttpBroadcast server cache by default in spark.local.dir instead of java.io.tmpdir
| -rw-r--r-- | core/src/main/scala/spark/broadcast/HttpBroadcast.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala index 7eb4ddb74f..96dc28f12a 100644 --- a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala +++ b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala @@ -89,7 +89,7 @@ private object HttpBroadcast extends Logging { } private def createServer() { - broadcastDir = Utils.createTempDir() + broadcastDir = Utils.createTempDir(System.getProperty("spark.local.dir", System.getProperty("java.io.tmpdir"))) server = new HttpServer(broadcastDir) server.start() serverUri = server.uri |