oozie java api提交作业-白红宇

今晚试验用java的api来提交代码，由于代码是在我机器上写的，然后提交到我的虚拟机集群当中去，所以中间产生了一个错误。。要想在任意一台机器上向oozie提交作业的话，需要对hadoop的core-site.xml文件进行设置，复制到所有机器上，然后重启hadoop集群。

设置如下：


          
      
       hadoop.proxyuser.cenyuhai.hosts
           
      
       *
       
      
          
      
       hadoop.proxyuser.cenyuhai.groups
           
      
       *

这里都设置成星号，则为任意机器，任意账号。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);         }

代码非常简单，先new一个OozieClient出来，然后创建一个配置文件Properties类，然后把我们用文件的Job.Properties里面写的所有参数都设置进去就行啦，然后调用run方法就打完收工了，简单吧。提交完了之后发现作业还是失败了，没关系，查看了一下详细的失败原因，发现不是因为workflow.xml设置输入输出目录的时候使用了账户的原因，没关系啦，随便它，反正提交是成功啦。

f98417e57b01a1278316f83826220f7ee30189a2