Изменение пользователя контекста сервера Spark Job во время выполнения

Question

Как я могу изменить пользователя контекста, созданного в Spark Job Server? Я хочу изменить пользователя, которого я получаю на sparkSession.sparkContext.sparkUser ();

Answer 1

выполните следующие шаги.

[root@localhost bin]# export HADOOP_USER_NAME=praveen //set this environment variable
[root@localhost bin]# ./spark-shell // start the spark shell

scala> sc.sparkUser //Spark context available as sc.
res0: String = praveen

Таким образом вы можете изменить значение sparkUser.