You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by an...@apache.org on 2014/11/20 03:19:01 UTC
spark git commit: [SPARK-4446] [SPARK CORE]
Repository: spark
Updated Branches:
refs/heads/master 0eb4a7fb0 -> e216ffaea
[SPARK-4446] [SPARK CORE]
MetadataCleaner schedule task with a wrong param for delay time .
Author: Leolh <le...@gmail.com>
Closes #3306 from Leolh/master and squashes the following commits:
4a21f4e [Leolh] Update MetadataCleaner.scala
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e216ffae
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e216ffae
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e216ffae
Branch: refs/heads/master
Commit: e216ffaead983274428052caa992b20760b2c5e0
Parents: 0eb4a7f
Author: Leolh <le...@gmail.com>
Authored: Wed Nov 19 18:18:55 2014 -0800
Committer: Andrew Or <an...@databricks.com>
Committed: Wed Nov 19 18:18:55 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/e216ffae/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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org