Skip to content

Commit d97f27b

Browse files
author
Marcelo Vanzin
committed
Add warning about RPC encryption being disabled.
1 parent e76dd15 commit d97f27b

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,12 @@ object SparkEnv extends Logging {
234234
}
235235

236236
val securityManager = new SecurityManager(conf, ioEncryptionKey)
237+
ioEncryptionKey.foreach { _ =>
238+
if (!securityManager.isSaslEncryptionEnabled()) {
239+
logWarning("I/O encryption enabled without RPC encryption: keys will be visible on the " +
240+
"wire.")
241+
}
242+
}
237243

238244
val systemName = if (isDriver) driverSystemName else executorSystemName
239245
val rpcEnv = RpcEnv.create(systemName, bindAddress, advertiseAddress, port, conf,

0 commit comments

Comments
 (0)