今晚试验用java的api来提交代码，由于代码是在我机器上写的，然后提交到我的虚拟机集群当中去，所以中间产生了一个错误。。要想在任意一台机器上向oozie提交作业的话，需要对hadoop的core-site.xml文件进行设置，复制到所有机器上，然后重启hadoop集群。
设置如下：
<property>
<name>hadoop.proxyuser.cenyuhai.hosts</name>
<value>*</value>
</property>
<property>
<name>hadoop.proxyuser.cenyuhai.groups</name>
<value>*</value>
</property>
这里都设置成星号，则为任意机器，任意账号。cenyuhai是我的本机账户。
然后就开始啦，用本机提交代码到oozie。代码如下：
OozieClient wc = new OozieClient("http://192.168.1.133:11000/oozie");
Properties conf = wc.createConfiguration();
//conf.setProperty(OozieClient.APP_PATH,"hdfs://192.168.1.133:9000" + appPath);
conf.setProperty("nameNode", "hdfs://192.168.1.133:9000");
conf.setProperty("queueName", "default");
conf.setProperty("examplesRoot", "examples");
conf.setProperty("oozie.wf.application.path", "${nameNode}/user/cenyuhai/${examplesRoot}/apps/map-reduce");
conf.setProperty("outputDir", "map-reduce");
conf.setProperty("jobTracker", "http://192.168.1.133:9001");
conf.setProperty("inputDir", input);
conf.setProperty("outputDir", output);
try {
String jobId = wc.run(conf);
return jobId;
} catch (OozieClientException e) {
log.error(e);
}
