如何分别测试作为oozie工作流一部分的hadoop MapReduce java操作(带有文件标记)？

Question

我试图在java中分别测试MapReduce作业，这是oozie工作流的一部分。我可以使用下面的命令在java中成功地测试MapReduce作业。

hadoop jar /tmp/lib/Example.jar com.example.MRDriver mapper=com.example.DataTransformMapper

挑战在于何时有标记作为oozie java操作的一部分。请建议如何使用文件标记模拟或测试此MapReduce作业。

<action name="JavaMRAction">
<java>
<job-xml>${hbase_site_xml}</job-xml>
<main-class>com.example.MRDriver</main-class>
<java-opts>-Dsun.security.krb5.debug=true</java-opts>
<arg>mapper=com.example.DataTransformMapper</arg>
<file>${hdfs_sharelib_hbase_path}hbase-client.jar#hbase-client.jar</file>
<file>${hdfs_sharelib_hbase_path}hbase-common.jar#hbase-common.jar</file> 
<file>${kerberos_keytab_file}#${kerberos_keytab_filename}</file>            
</java>
<ok to="NextAction" />
<error to="ErrorAction" />
</action>

Answer 1

使用hadoop jar命令的“hadoop jar”选项：https://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/CommandsManual.html#jar