diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-23 17:42:26 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-23 17:42:26 -0800 |
| commit | d853aa9658a87d644d483b1fa9d41c29e3ac0673 (patch) | |
| tree | 4a95469875543fd73e795185c335859fd442e71b /core | |
| parent | 41285eaae3642b73b3ac5007a35cc4e8f1d7d084 (diff) | |
| download | spark-d853aa9658a87d644d483b1fa9d41c29e3ac0673.tar.gz spark-d853aa9658a87d644d483b1fa9d41c29e3ac0673.tar.bz2 spark-d853aa9658a87d644d483b1fa9d41c29e3ac0673.zip | |
Change spark.cleaner.delay to spark.cleaner.ttl. Updated docs.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/util/MetadataCleaner.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/util/MetadataCleaner.scala b/core/src/main/scala/spark/util/MetadataCleaner.scala index a342d378ff..dafa906712 100644 --- a/core/src/main/scala/spark/util/MetadataCleaner.scala +++ b/core/src/main/scala/spark/util/MetadataCleaner.scala @@ -38,7 +38,7 @@ class MetadataCleaner(name: String, cleanupFunc: (Long) => Unit) extends Logging object MetadataCleaner { - def getDelaySeconds = System.getProperty("spark.cleaner.delay", "-1").toInt - def setDelaySeconds(delay: Int) { System.setProperty("spark.cleaner.delay", delay.toString) } + def getDelaySeconds = System.getProperty("spark.cleaner.ttl", "-1").toInt + def setDelaySeconds(delay: Int) { System.setProperty("spark.cleaner.ttl", delay.toString) } } |