You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/12 02:12:16 UTC
[2/3] git commit: Revert "Fix default TTL for metadata cleaner"
Revert "Fix default TTL for metadata cleaner"
This reverts commit 669ba4caa95014f4511f842206c3e506f1a41a7a.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/07b952e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/07b952e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/07b952e1
Branch: refs/heads/master
Commit: 07b952e1d1fa5257b0f781fe30d16d26dde91774
Parents: 22d4d62
Author: Patrick Wendell <pw...@gmail.com>
Authored: Sat Jan 11 16:07:10 2014 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Sat Jan 11 16:07:10 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/incubator-spark/blob/07b952e1/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 ac07a55..3d1e90a 100644
--- a/core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala
+++ b/core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala
@@ -74,7 +74,7 @@ object MetadataCleanerType extends Enumeration {
// initialization of StreamingContext. It's okay for users trying to configure stuff themselves.
object MetadataCleaner {
def getDelaySeconds(conf: SparkConf) = {
- conf.getInt("spark.cleaner.ttl", -1)
+ conf.getInt("spark.cleaner.ttl", 3500)
}
def getDelaySeconds(conf: SparkConf, cleanerType: MetadataCleanerType.MetadataCleanerType): Int =