Skip to content

Commit 669ba4c

Browse files
committed
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
1 parent 0ebc973 commit 669ba4c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/util/MetadataCleaner.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ object MetadataCleanerType extends Enumeration {
7474
// initialization of StreamingContext. It's okay for users trying to configure stuff themselves.
7575
object MetadataCleaner {
7676
def getDelaySeconds(conf: SparkConf) = {
77-
conf.getInt("spark.cleaner.ttl", 3500)
77+
conf.getInt("spark.cleaner.ttl", -1)
7878
}
7979

8080
def getDelaySeconds(conf: SparkConf, cleanerType: MetadataCleanerType.MetadataCleanerType): Int =

0 commit comments

Comments
 (0)