从命令行,可以将参数传递给 ToolRunner,如下所示:
hadoop jar myJar.jar com.Main -Dprop1=prop1value -Dprop2=prop2value
我想在 Oozie 的 MapReduce 操作中调用我的 MapReduce 作业。
我尝试在工作流程中定义属性,如下所示:
<property>
<name>param1</name>
<value>Hello World</value>
</property>
编辑 这就是我试图从我的 MapReduce 作业中读取参数的方式:
Job job = new Job();
Configuration conf = job.getConfiguration();
System.out.println(conf.get("param1"));
但我无法从 mapreduce 程序中读取它。
尽管我的问题是向 ToolRunner 传递参数,但我认为这不是 toolrunner 特有的。它一般用于使用 Oozie MapReduce 操作调用的 MapReduce 作业。任何帮助将不胜感激!