fix issue

apache · Feb 26, 2015 · 7a5b9c5 · 7a5b9c5
1 parent 31674ee
commit 7a5b9c5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala
@@ -49,8 +49,8 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
 
   // Interval between each check for event log updates
   private val UPDATE_INTERVAL_MS = conf.getOption("spark.history.fs.update.interval.seconds")
-    .orElse(Some(SparkConf.translateConfKey("spark.history.fs.updateInterval", true)))
-    .orElse(Some(SparkConf.translateConfKey("spark.history.updateInterval", true)))
+    .orElse(conf.getOption(SparkConf.translateConfKey("spark.history.fs.updateInterval", true)))
+    .orElse(conf.getOption(SparkConf.translateConfKey("spark.history.updateInterval", true)))
     .map(_.toInt)
     .getOrElse(10) * 1000