指定Oozie Java节点的Hadoop属性(2)

<actionname="java_checkApp">
                <java>
                      <job-tracker>${jobTracker}</job-tracker>
                      <name-node>${nameNode}</name-node>
                        <configuration>
                                <property>
                                      <name>mapred.job.queue.name</name>
                                      <value>${queueName}</value>
                              </property>
                                <property>
                                        <name>oozie.launcher.mapreduce.task.classpath.user.precedence</name>
                                      <value>true</value>
                              </property>
                        </configuration>
                      <main-class>com.jd.ebsdi.hadoop.mapreduce.ooziemain.main.DoCheck
                        </main-class>
                      <arg>{"dbSetPointerType":"pointerTime","wfName":"${wf:name()}","coorTime":"${wf:conf("nominalTime")}","wfPath":"${wf_app_path}","failClockThresholdValue":"${failThreshold}","checkLockFrequence":"${checkLockSequence}","waitingThresholdValue":"${waitingThreshold}"}
                        </arg>
                        <capture-output/>
                </java>
                <okto="java_InitialData" />
                <error to="kill"/>
      </action>

在hadoop的job配置文件中

hdfs://hadoop-master.xxx.com:8020/home/data/hadoop/cache/mapred/staging/houchangren/.staging/job_201401261826_18982/job.xml

可以看到

如下的属性

这个是oozie的属性

指定Oozie Java节点的Hadoop属性

下边中是解析后的hadoop属性

指定Oozie Java节点的Hadoop属性

恩恩,事情搞定了

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:http://www.heiqu.com/ddb959c7006d2c8a3d059d62d690f630.html