Repository: spark Updated Branches: refs/heads/branch-1.2 4a5c3d21b -> 83d24efb0
[SPARK-4446] [SPARK CORE] MetadataCleaner schedule task with a wrong param for delay time . Author: Leolh <[email protected]> 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 <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/83d24efb Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/83d24efb Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/83d24efb Branch: refs/heads/branch-1.2 Commit: 83d24efb074f9b9f9aacc1e486c994a6799e981d Parents: 4a5c3d2 Author: Leolh <[email protected]> Authored: Wed Nov 19 18:18:55 2014 -0800 Committer: Andrew Or <[email protected]> Committed: Wed Nov 19 18:19:06 2014 -0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/83d24efb/core/src/main/scala/org/apache/spark/util/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 index 2889e17..ac40f19 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() { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
