diff --git a/core/src/main/scala/org/apache/spark/SparkConf.scala b/core/src/main/scala/org/apache/spark/SparkConf.scala index 00a0f61ab47bc..02492f947024b 100644 --- a/core/src/main/scala/org/apache/spark/SparkConf.scala +++ b/core/src/main/scala/org/apache/spark/SparkConf.scala @@ -714,8 +714,8 @@ private[spark] object SparkConf extends Logging { KERBEROS_RELOGIN_PERIOD.key -> Seq( AlternateConfig("spark.yarn.kerberos.relogin.period", "3.0")), KERBEROS_FILESYSTEMS_TO_ACCESS.key -> Seq( - AlternateConfig("spark.yarn.access.namenodes", "2.2"), - AlternateConfig("spark.yarn.access.hadoopFileSystems", "3.0")), + AlternateConfig("spark.yarn.access.hadoopFileSystems", "3.0"), + AlternateConfig("spark.yarn.access.namenodes", "2.2")), "spark.kafka.consumer.cache.capacity" -> Seq( AlternateConfig("spark.sql.kafkaConsumerCache.capacity", "3.0")) ) diff --git a/core/src/test/scala/org/apache/spark/SparkConfSuite.scala b/core/src/test/scala/org/apache/spark/SparkConfSuite.scala index 7ae1eac1db18a..e5a3d4216db2f 100644 --- a/core/src/test/scala/org/apache/spark/SparkConfSuite.scala +++ b/core/src/test/scala/org/apache/spark/SparkConfSuite.scala @@ -277,8 +277,11 @@ class SparkConfSuite extends SparkFunSuite with LocalSparkContext with ResetSyst conf.set("spark.yarn.access.namenodes", "testNode") assert(conf.get(KERBEROS_FILESYSTEMS_TO_ACCESS) === Array("testNode")) - conf.set("spark.yarn.access.hadoopFileSystems", "testNode") - assert(conf.get(KERBEROS_FILESYSTEMS_TO_ACCESS) === Array("testNode")) + conf.set("spark.yarn.access.hadoopFileSystems", "testNode2") + assert(conf.get(KERBEROS_FILESYSTEMS_TO_ACCESS) === Array("testNode2")) + + conf.set("spark.yarn.access.namenodes", "testNode3") + assert(conf.get(KERBEROS_FILESYSTEMS_TO_ACCESS) === Array("testNode2")) } test("akka deprecated configs") {