[SPARK-4446] [SPARK CORE]

Leolh · Andrew Or · commit e216ffaead98 · 2014-11-19T18:18:55.000-08:00
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
diff --git 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() {

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ private[spark] class MetadataCleaner(`
`52`	`52`	`logDebug(`
`53`	`53`	`"Starting metadata cleaner for " + name + " with delay of " + delaySeconds + " seconds " +`
`54`	`54`	`"and period of " + periodSeconds + " secs")`
`55`		`- timer.schedule(task, periodSeconds * 1000, periodSeconds * 1000)`
	`55`	`+ timer.schedule(task, delaySeconds * 1000, periodSeconds * 1000)`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`def cancel() {`