Skip to content

Commit 8fb43e6

Browse files
author
Andrew Or
committed
Privatize SparkConf.translateConfKey
1 parent b38dec2 commit 8fb43e6

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

core/src/main/scala/org/apache/spark/SparkConf.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -407,7 +407,7 @@ private[spark] object SparkConf extends Logging {
407407
* @param warn Whether to print a warning if the key is deprecated. Warnings will be printed
408408
* only once for each key.
409409
*/
410-
def translateConfKey(userKey: String, warn: Boolean = false): String = {
410+
private def translateConfKey(userKey: String, warn: Boolean = false): String = {
411411
deprecatedConfigs.get(userKey)
412412
.map { deprecatedKey =>
413413
if (warn) {

core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,8 +49,8 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
4949

5050
// Interval between each check for event log updates
5151
private val UPDATE_INTERVAL_MS = conf.getOption("spark.history.fs.update.interval.seconds")
52-
.orElse(conf.getOption(SparkConf.translateConfKey("spark.history.fs.updateInterval", true)))
53-
.orElse(conf.getOption(SparkConf.translateConfKey("spark.history.updateInterval", true)))
52+
.orElse(conf.getOption("spark.history.fs.updateInterval"))
53+
.orElse(conf.getOption("spark.history.updateInterval"))
5454
.map(_.toInt)
5555
.getOrElse(10) * 1000
5656

0 commit comments

Comments
 (0)