【发布时间】:2015-07-20 16:46:41
【问题描述】:
我有一个由 oozie 协调员安排的 mapreduce 作业,每 4 小时运行一次。这个 mapreduce 作业有一个参数,比如说 k,它的值是在 job.config 文件中设置的。我想知道如果我在两次运行之间更改此参数的值,它是选择更新的(新)值还是坚持原始(旧)值?
【问题讨论】:
我有一个由 oozie 协调员安排的 mapreduce 作业,每 4 小时运行一次。这个 mapreduce 作业有一个参数,比如说 k,它的值是在 job.config 文件中设置的。我想知道如果我在两次运行之间更改此参数的值,它是选择更新的(新)值还是坚持原始(旧)值?
【问题讨论】:
如果作业处于运行模式,它将坚持自己的旧参数,如果作业正在等待调度运行,那么它将采用最新值:)。
【讨论】:
其实,有一种迂回的方式可以在运行时“动态”获取参数值:
${wf:actionData("DummyShellAction")["some.key"]}
http://oozie.apache.org/docs/4.0.0/WorkflowFunctionalSpec.html#a4.2.6_Hadoop_Jobs_EL_Function
【讨论】: