diff options
| author | Matei Zaharia <matei@databricks.com> | 2014-01-10 00:21:36 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@databricks.com> | 2014-01-10 00:21:36 -0800 |
| commit | 669ba4caa95014f4511f842206c3e506f1a41a7a (patch) | |
| tree | e6f530a6085b9345ed9b5464f81740fafbf62316 | |
| parent | 0ebc97305a0e23a9d2183c335998c800c5d865b7 (diff) | |
| download | spark-669ba4caa95014f4511f842206c3e506f1a41a7a.tar.gz spark-669ba4caa95014f4511f842206c3e506f1a41a7a.tar.bz2 spark-669ba4caa95014f4511f842206c3e506f1a41a7a.zip | |
Fix default TTL for metadata cleaner
It seems to have been set to 3500 in a previous commit for debugging,
but it should be off by default
| -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 3d1e90a352..ac07a55cb9 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", 3500) + conf.getInt("spark.cleaner.ttl", -1) } def getDelaySeconds(conf: SparkConf, cleanerType: MetadataCleanerType.MetadataCleanerType): Int = |