В качестве первого шага, если вы добавите флаг --verbose
к вашей команде spark-submit
, Spark распечатает параметры конфигурации, и вы увидите:
(spark.authenticate.enableSaslEncryption, true)
Далее вы можетевключите ведение журнала DEBUG
(с помощью файла log4j.properties
- см. документы ) и найдите в журналах записи, в которых упоминается Sasl.
При включенном шифровании SASL вы увидите ведение журнала из классов, включая:
- SaslRpcClient
- TSaslTransport
- SparkSaslServer
- SaslRpcHandler
например:
SparkSaslServer: SASL Authorization complete, authorized set to true
SaslRpcHandler: SASL authentication successful for channel TransportClient{...}