Skip to content

Commit af4d89d

Browse files
committed
minor refactering
1 parent e88993e commit af4d89d

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

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

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -188,12 +188,11 @@ import org.apache.spark.util.Utils
188188

189189
private[spark] class SecurityManager(sparkConf: SparkConf)
190190
extends Logging with SecretKeyHolder {
191-
import SecurityManager._
192191

193192
// key used to store the spark secret in the Hadoop UGI
194193
private val sparkSecretLookupKey = "sparkCookie"
195194

196-
private val authOn = sparkConf.getBoolean(SPARK_AUTH_CONF, false)
195+
private val authOn = sparkConf.getBoolean(SecurityManager.SPARK_AUTH_CONF, false)
197196
// keep spark.ui.acls.enable for backwards compatibility with 1.0
198197
private var aclsOn =
199198
sparkConf.getBoolean("spark.acls.enable", sparkConf.getBoolean("spark.ui.acls.enable", false))
@@ -367,8 +366,8 @@ private[spark] class SecurityManager(sparkConf: SparkConf)
367366
} else {
368367
// user must have set spark.authenticate.secret config
369368
// For Master/Worker, auth secret is in conf; for Executors, it is in env variable
370-
sys.env.get(ENV_AUTH_SECRET)
371-
.orElse(sparkConf.getOption(SPARK_AUTH_SECRET_CONF)) match {
369+
sys.env.get(SecurityManager.ENV_AUTH_SECRET)
370+
.orElse(sparkConf.getOption(SecurityManager.SPARK_AUTH_SECRET_CONF)) match {
372371
case Some(value) => value
373372
case None => throw new Exception("Error: a secret key must be specified via the " +
374373
"spark.authenticate.secret config")

0 commit comments

Comments
 (0)