diff options
author | Leolh <leosandylh@gmail.com> | 2014-11-19 18:18:55 -0800 |
---|---|---|
committer | Andrew Or <andrew@databricks.com> | 2014-11-19 18:18:55 -0800 |
commit | e216ffaead983274428052caa992b20760b2c5e0 (patch) | |
tree | cc875636b3a7d9cef57083906729a81b7ca9364d | |
parent | 0eb4a7fb0fa1fa56677488cbd74eb39e65317621 (diff) | |
download | spark-e216ffaead983274428052caa992b20760b2c5e0.tar.gz spark-e216ffaead983274428052caa992b20760b2c5e0.tar.bz2 spark-e216ffaead983274428052caa992b20760b2c5e0.zip |
[SPARK-4446] [SPARK CORE]
MetadataCleaner schedule task with a wrong param for delay time .
Author: Leolh <leosandylh@gmail.com>
Closes #3306 from Leolh/master and squashes the following commits:
4a21f4e [Leolh] Update MetadataCleaner.scala
-rw-r--r-- | core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala b/core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala index 2889e171f6..ac40f19ed6 100644 --- a/core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala +++ b/core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala @@ -52,7 +52,7 @@ private[spark] class MetadataCleaner( logDebug( "Starting metadata cleaner for " + name + " with delay of " + delaySeconds + " seconds " + "and period of " + periodSeconds + " secs") - timer.schedule(task, periodSeconds * 1000, periodSeconds * 1000) + timer.schedule(task, delaySeconds * 1000, periodSeconds * 1000) } def cancel() { |