File tree Expand file tree Collapse file tree 2 files changed +11
-1
lines changed
main/scala/org/apache/spark
test/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +11
-1
lines changed Original file line number Diff line number Diff line change @@ -738,7 +738,6 @@ private[spark] object SparkConf extends Logging {
738738 */
739739 def isExecutorStartupConf (name : String ): Boolean = {
740740 (name.startsWith(" spark.auth" ) && name != SecurityManager .SPARK_AUTH_SECRET_CONF ) ||
741- name.startsWith(" spark.ssl" ) ||
742741 name.startsWith(" spark.rpc" ) ||
743742 name.startsWith(" spark.network" ) ||
744743 isSparkPortConf(name)
Original file line number Diff line number Diff line change @@ -353,6 +353,17 @@ class SparkConfSuite extends SparkFunSuite with LocalSparkContext with ResetSyst
353353 }
354354 }
355355
356+ test(" SPARK-26998: SSL configuration not needed on executors" ) {
357+ val conf = new SparkConf (false )
358+ conf.set(" spark.ssl.enabled" , " true" )
359+ conf.set(" spark.ssl.keyPassword" , " password" )
360+ conf.set(" spark.ssl.keyStorePassword" , " password" )
361+ conf.set(" spark.ssl.trustStorePassword" , " password" )
362+
363+ val filtered = conf.getAll.filter { case (k, _) => SparkConf .isExecutorStartupConf(k) }
364+ assert(filtered.isEmpty)
365+ }
366+
356367 test(" SPARK-27244 toDebugString redacts sensitive information" ) {
357368 val conf = new SparkConf (loadDefaults = false )
358369 .set(" dummy.password" , " dummy-password" )
You can’t perform that action at this time.
0 commit comments