How to enable SASL encryption

Question

Hi. I have enabled encryption for my spark application and I am using older shuffle services. I want to encryption to be SASL. How can I enable this?

Answer 1

You can use dynamic configuration setting to enable this: 

val sc = new SparkContext(new SparkConf())

./bin/spark-submit <all your existing options> --spark.authenticate.enableSaslEncryption=true