|
@@ -367,6 +367,7 @@ public class ShuffleHandler extends AuxiliaryService {
|
|
|
SHUFFLE = getShuffle(conf);
|
|
|
if (conf.getBoolean(MRConfig.SHUFFLE_SSL_ENABLED_KEY,
|
|
|
MRConfig.SHUFFLE_SSL_ENABLED_DEFAULT)) {
|
|
|
+ LOG.info("Encrypted shuffle is enabled.");
|
|
|
sslFactory = new SSLFactory(SSLFactory.Mode.SERVER, conf);
|
|
|
sslFactory.init();
|
|
|
}
|