aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-02-25 14:34:55 -0800
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-02-25 14:34:55 -0800
commit568bdaf8ae784c9b832f564cb99f1b81ad487f73 (patch)
tree7c9ac6050bb6c26bc6f33dac15253c1fa3e7a1cb /core
parent5d4a0ac794bff3bc3c579ab6e0658b17bdeeab43 (diff)
downloadspark-568bdaf8ae784c9b832f564cb99f1b81ad487f73.tar.gz
spark-568bdaf8ae784c9b832f564cb99f1b81ad487f73.tar.bz2
spark-568bdaf8ae784c9b832f564cb99f1b81ad487f73.zip
Set spark.deploy.spreadOut to true by default in 0.7 (improves locality)
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/deploy/master/Master.scala2
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)