diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-07-29 21:40:56 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-08-01 15:26:26 -0700 |
| commit | f1d2ad550edb83319fe3e187dad2151a8d0aeae1 (patch) | |
| tree | f5554db880ad0da07a24086468be1f332f069f39 | |
| parent | 12d9c82c9b2a5040a2d1e5ab23ab44b41cbe1807 (diff) | |
| download | spark-f1d2ad550edb83319fe3e187dad2151a8d0aeae1.tar.gz spark-f1d2ad550edb83319fe3e187dad2151a8d0aeae1.tar.bz2 spark-f1d2ad550edb83319fe3e187dad2151a8d0aeae1.zip | |
under_scores --> camelCase for config options
| -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 36c22d0873..0aed4b9802 100644 --- a/core/src/main/scala/spark/deploy/master/Master.scala +++ b/core/src/main/scala/spark/deploy/master/Master.scala @@ -38,7 +38,7 @@ import spark.util.AkkaUtils private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Actor with Logging { val DATE_FORMAT = new SimpleDateFormat("yyyyMMddHHmmss") // For application IDs val WORKER_TIMEOUT = System.getProperty("spark.worker.timeout", "60").toLong * 1000 - val RETAINED_APPLICATIONS = System.getProperty("spark.deploy.retained_applications", "1000").toInt + val RETAINED_APPLICATIONS = System.getProperty("spark.deploy.retainedApplications", "200").toInt var nextAppNumber = 0 val workers = new HashSet[WorkerInfo] |