1. //设置hadoop用户名
  2. System.setProperty("HADOOP_USER_NAME", "admin")
  3. //初始化SparkConf对象,设置基本任务参数
  4. val conf = new SparkConf()
  5. //设置目标Master机器地址
  6. .setMaster("local[*]")
  7. //设置任务名称
  8. .setAppName("WC")
  9. // .setMaster("spark://hdp03:10016")
  10. .setJars(List("/Users/twx/code-space/internet/SparkSyllabusBook/chapter-3/target/chapter-3-1.0-SNAPSHOT.jar"))
  11. .setIfMissing("spark.driver.host", "172.26.1.184")
  12. /实例化SparkContextSpark的对外接口,即负责用户与Spark内部的交互通信
  13. val sc = new SparkContext(conf)

方式二

在VM options中指定hadoop_user_name和spark.master

image.png