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 {
738
738
*/
739
739
def isExecutorStartupConf (name : String ): Boolean = {
740
740
(name.startsWith(" spark.auth" ) && name != SecurityManager .SPARK_AUTH_SECRET_CONF ) ||
741
- name.startsWith(" spark.ssl" ) ||
742
741
name.startsWith(" spark.rpc" ) ||
743
742
name.startsWith(" spark.network" ) ||
744
743
isSparkPortConf(name)
Original file line number Diff line number Diff line change @@ -353,6 +353,17 @@ class SparkConfSuite extends SparkFunSuite with LocalSparkContext with ResetSyst
353
353
}
354
354
}
355
355
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
+
356
367
test(" SPARK-27244 toDebugString redacts sensitive information" ) {
357
368
val conf = new SparkConf (loadDefaults = false )
358
369
.set(" dummy.password" , " dummy-password" )
You can’t perform that action at this time.
0 commit comments