diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-25 14:34:55 -0800 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-25 14:34:55 -0800 |
commit | 568bdaf8ae784c9b832f564cb99f1b81ad487f73 (patch) | |
tree | 7c9ac6050bb6c26bc6f33dac15253c1fa3e7a1cb | |
parent | 5d4a0ac794bff3bc3c579ab6e0658b17bdeeab43 (diff) | |
download | spark-568bdaf8ae784c9b832f564cb99f1b81ad487f73.tar.gz spark-568bdaf8ae784c9b832f564cb99f1b81ad487f73.tar.bz2 spark-568bdaf8ae784c9b832f564cb99f1b81ad487f73.zip |
Set spark.deploy.spreadOut to true by default in 0.7 (improves locality)
-rw-r--r-- | core/src/main/scala/spark/deploy/master/Master.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/deploy/master/Master.scala b/core/src/main/scala/spark/deploy/master/Master.scala index b7f167425f..d5188a4779 100644 --- a/core/src/main/scala/spark/deploy/master/Master.scala +++ b/core/src/main/scala/spark/deploy/master/Master.scala @@ -43,7 +43,7 @@ private[spark] class Master(ip: String, port: Int, webUiPort: Int) extends Actor // As a temporary workaround before better ways of configuring memory, we allow users to set // a flag that will perform round-robin scheduling across the nodes (spreading out each app // among all the nodes) instead of trying to consolidate each app onto a small # of nodes. - val spreadOutApps = System.getProperty("spark.deploy.spreadOut", "false").toBoolean + val spreadOutApps = System.getProperty("spark.deploy.spreadOut", "true").toBoolean override def preStart() { logInfo("Starting Spark master at spark://" + ip + ":" + port) |