diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-28 01:29:27 -0800 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-28 01:29:27 -0800 |
commit | 286f8f876ff495df33a7966e77ca90d69f338450 (patch) | |
tree | 1eded0e8290d83cc321502da19a290cf0671658a | |
parent | f03d9760fd8ac67fd0865cb355ba75d2eff507fe (diff) | |
download | spark-286f8f876ff495df33a7966e77ca90d69f338450.tar.gz spark-286f8f876ff495df33a7966e77ca90d69f338450.tar.bz2 spark-286f8f876ff495df33a7966e77ca90d69f338450.zip |
Change time unit in MetadataCleaner to seconds
-rw-r--r-- | core/src/main/scala/spark/util/MetadataCleaner.scala | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/core/src/main/scala/spark/util/MetadataCleaner.scala b/core/src/main/scala/spark/util/MetadataCleaner.scala index 51fb440108..6cf93a9b17 100644 --- a/core/src/main/scala/spark/util/MetadataCleaner.scala +++ b/core/src/main/scala/spark/util/MetadataCleaner.scala @@ -9,7 +9,6 @@ import spark.Logging * Runs a timer task to periodically clean up metadata (e.g. old files or hashtable entries) */ class MetadataCleaner(name: String, cleanupFunc: (Long) => Unit) extends Logging { - val delaySeconds = MetadataCleaner.getDelaySeconds val periodSeconds = math.max(10, delaySeconds / 10) val timer = new Timer(name + " cleanup timer", true) @@ -39,7 +38,7 @@ class MetadataCleaner(name: String, cleanupFunc: (Long) => Unit) extends Logging object MetadataCleaner { - def getDelaySeconds = (System.getProperty("spark.cleaner.delay", "-100").toDouble * 60).toInt - def setDelaySeconds(delay: Long) { System.setProperty("spark.cleaner.delay", delay.toString) } + def getDelaySeconds = System.getProperty("spark.cleaner.delay", "-1").toInt + def setDelaySeconds(delay: Int) { System.setProperty("spark.cleaner.delay", delay.toString) } } |