第一件事是，你可以尝试为同名用户

root@host:~# su - hdfs
hdfs@host:~$ hadoop fs -mkdir /user/anonymous
hdfs@host:~$ hadoop fs -chown anonymous /user/anonymous

一般来说
出口 HADOOP_USER_NAME=youruser 之前 spark-submit 会有用的。连同spark一起提交如下配置。 --conf "spark.yarn.appMasterEnv.HADOOP_USER_NAME=${HADDOP_USER_NAME}" \ 或者你可以尝试使用 sudo -su username spark-submit --class 你的班级
看到这个了吗
注意：这个用户名设置应该是您初始集群设置的一部分，理想情况下，如果它完成了，那么就不需要执行上面所有的操作，而且它看起来毫无意义。
我个人不喜欢用户名硬编码的代码，它应该从外面的Spark工作。

要验证运行的用户，请运行以下命令：-

sc.sparkUser

它将向您显示当前用户，然后您可以尝试根据下面的代码设置新用户
在scala中，您可以通过

System.setProperty("HADOOP_USER_NAME","newUserName")

如果您使用的是spark，则需要在spark上下文中设置用户名。

System.setProperty("HADOOP_USER_NAME","newUserName")
  val spark = SparkSession
    .builder()
    .appName("SparkSessionApp")
    .master("local[*]")
    .getOrCreate()

  println(spark.sparkContext.sparkUser)