Oozie 协调器如何对底层工作流更改做出反应?
How does an Oozie coordinator react on an underlying workflow change?
我有一个关于 Apache Oozie 的问题,更具体地说是关于 CDH 发行版的问题。
当协调器使用的工作流被修改时,协调器会发生什么情况?
例如,工作流现在使用一个由变量自动填充的额外参数。这在理论上不需要对协调器进行任何更改。
运行 协调器是否仍然使用初始工作流的配置,或者他们是否动态适应新工作流。如果他们仍然使用旧配置,那么我需要定义一个新的协调器还是重新提交相同的协调器?
它是这样工作的:每个提交的协调器都有一组固定的变量和参数(配置文件)。 -change 选项允许您更改协调器的以下属性:
- endtime:协调器作业的结束时间。
- 并发性:协调器作业的并发性。
- pausetime:协调器作业的暂停时间。
除 Coordinator 协调器名称、频率、开始时间、结束时间和时区之外的所有内容都可以使用 -update 选项进行更改。详见官方文档:
在配置文件中,您通常指向 hdfs 中的协调器文件,然后指向 hdfs 中的工作流文件。如果您在 hdfs 中更改其中任何一个,协调器下次触发时将使用 new/modified 文件。这同样适用于工作流操作中使用的所有文件,例如shell 个脚本,Jar-files,...
我有一个关于 Apache Oozie 的问题,更具体地说是关于 CDH 发行版的问题。
当协调器使用的工作流被修改时,协调器会发生什么情况? 例如,工作流现在使用一个由变量自动填充的额外参数。这在理论上不需要对协调器进行任何更改。 运行 协调器是否仍然使用初始工作流的配置,或者他们是否动态适应新工作流。如果他们仍然使用旧配置,那么我需要定义一个新的协调器还是重新提交相同的协调器?
它是这样工作的:每个提交的协调器都有一组固定的变量和参数(配置文件)。 -change 选项允许您更改协调器的以下属性:
- endtime:协调器作业的结束时间。
- 并发性:协调器作业的并发性。
- pausetime:协调器作业的暂停时间。
除 Coordinator 协调器名称、频率、开始时间、结束时间和时区之外的所有内容都可以使用 -update 选项进行更改。详见官方文档:
在配置文件中,您通常指向 hdfs 中的协调器文件,然后指向 hdfs 中的工作流文件。如果您在 hdfs 中更改其中任何一个,协调器下次触发时将使用 new/modified 文件。这同样适用于工作流操作中使用的所有文件,例如shell 个脚本,Jar-files,...