如何从Oozie工作流向Hadoop ToolRunner (或任何MapReduce操作)传递参数

Question

在命令行中，参数可以按如下方式传递给ToolRunner：

hadoop jar myJar.jar com.Main -Dprop1=prop1value -Dprop2=prop2value

我想从Oozie调用我的MapReduce作业作为MapReduce操作的一部分。

我尝试在工作流中定义属性如下：

<property>
     <name>param1</name>
     <value>Hello World</value>
</property>

编辑--这是我试图从作业中读取参数的方式：

Job job = new Job();
Configuration conf = job.getConfiguration();
System.out.println(conf.get("param1"));

但我无法从mapreduce程序中读到它。

虽然我的问题是向ToolRunner传递参数，但我并不认为这是特定于工具运行程序的。对于使用Oozie MapReduce操作调用的MapReduce作业，它是通用的。任何帮助都将不胜感激！

Answer 1

你试过这些例子了吗？这里是Action和Workflows