diff options
| author | Leolh <leosandylh@gmail.com> | 2014-11-19 18:18:55 -0800 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2014-11-19 18:19:06 -0800 |
| commit | 83d24efb074f9b9f9aacc1e486c994a6799e981d (patch) | |
| tree | 25904ab4343b075b9b8da5abc8fdf5a36458a9e3 /core | |
| parent | 4a5c3d21b4df8fa506fe0365a0718c94bbc1cd1b (diff) | |
| download | spark-83d24efb074f9b9f9aacc1e486c994a6799e981d.tar.gz spark-83d24efb074f9b9f9aacc1e486c994a6799e981d.tar.bz2 spark-83d24efb074f9b9f9aacc1e486c994a6799e981d.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
(cherry picked from commit e216ffaead983274428052caa992b20760b2c5e0)
Signed-off-by: Andrew Or <andrew@databricks.com>
Diffstat (limited to 'core')
| -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() { |