CHG conf from using createOptional to createWithDefault(false)

apache · May 30, 2018 · 0e78b38 · 0e78b38
1 parent 2a8ab8d
commit 0e78b38
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...gers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocatorBlacklistTracker.scala b/...gers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocatorBlacklistTracker.scala
@@ -54,8 +54,7 @@ private[spark] class YarnAllocatorBlacklistTracker(
   private val blacklistTimeoutMillis =
     sparkConf.get(BLACKLIST_TIMEOUT_CONF).getOrElse(Utils.timeStringAsMs(defaultTimeout))
 
-  private val launchBlacklistEnabled =
-    sparkConf.get(YARN_EXECUTOR_LAUNCH_BLACKLIST_ENABLED).getOrElse(false)
+  private val launchBlacklistEnabled = sparkConf.get(YARN_EXECUTOR_LAUNCH_BLACKLIST_ENABLED)
 
   private val maxFailuresPerHost = sparkConf.get(MAX_FAILED_EXEC_PER_NODE)
 

diff --git a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/config.scala b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/config.scala
@@ -332,7 +332,7 @@ package object config {
   private[spark] val YARN_EXECUTOR_LAUNCH_BLACKLIST_ENABLED =
     ConfigBuilder("spark.yarn.blacklist.executor.launch.blacklisting.enabled")
       .booleanConf
-      .createOptional
+      .createWithDefault(false)
 
   private[spark] val YARN_BLACKLIST_MAX_NODE_BLACKLIST_RATIO =
     ConfigBuilder("spark.yarn.blacklist.maxNodeBlacklistRatio")