File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -114,7 +114,8 @@ private[spark] class SparkSaslClient(securityMgr: SecurityManager) extends Logg
114114 SparkSaslServer .encodeIdentifier(securityMgr.getSaslUser().getBytes(" utf-8" ))
115115 private val secretKey = securityMgr.getSecretKey()
116116 private val userPassword : Array [Char ] =
117- SparkSaslServer .encodePassword(if (secretKey != null ) secretKey.getBytes(" utf-8" ) else " " .getBytes(" utf-8" ))
117+ SparkSaslServer .encodePassword(if (secretKey != null ) secretKey.getBytes(" utf-8" ) else
118+ " " .getBytes(" utf-8" ))
118119
119120 /**
120121 * Implementation used to respond to SASL request from the server.
Original file line number Diff line number Diff line change @@ -1021,8 +1021,8 @@ private[spark] object Utils extends Logging {
10211021 " ln -sf "
10221022 }
10231023 import scala .sys .process ._
1024- (linkCmd + src.getAbsolutePath() + " " + dst.getPath() + cmdSuffix) lines_! ProcessLogger (line =>
1025- (logInfo(line)))
1024+ (linkCmd + src.getAbsolutePath() + " " + dst.getPath() + cmdSuffix) lines_!
1025+ ProcessLogger (line => (logInfo(line)))
10261026 }
10271027
10281028
You can’t perform that action at this time.
0 commit comments