[TOC] # 前提 我們本地開發好了,然后main運行,這是在本地跑的,沒有提交到yarn上 如果我們想本地run的時候能直接提交到yarn上該如何做 # 修改源碼 他的源碼中有個YARNRunner這個類,他就是個客戶端和yarn打交道 如果我們想修改他的話,我們只需要建個同名的包和類 我們也建立個這個包 ~~~ package org.apache.hadoop.mapred; ~~~ 然后把YARNRunner這個類也拷貝過來 如果你工程中有這個類的話,他會優先使用你工程中的 # 工程中修改 然后我們的main中要添加這些 ~~~ Configuration conf = new Configuration(); //設置權限,也可以在vm那邊偽造 System.setProperty("HADOOP_USER_NAME", "root"); conf.set("fs.defaultFS","hdfs://master:9000"); conf.set("mapreduce.framework.name","yarn"); conf.set("yarn.resourcemanager.hostname","master"); //這里要設置jar包所在位置 job.setJar("mapreduce.job.jar", "D:/wordCount.jar"); Job job = Job.getInstance(conf); ~~~ 然后我們把jar包打包成wordCount.jar,放到D盤下 然后我們run運行