1

我定义了一个 Oozie 协调员工作，如下所示：

<coordinator-app name="edu-apollogrp-DFE" frequency="${coord:minutes(15)}" start="${start}" end="${end}" timezone="${timezone}" xmlns="uri:oozie:coordinator:0.1">
    <controls>
            <concurrency>1</concurrency>
    </controls>
    <action>
            <workflow>
                    <app-path>${nameNode}/user/${user}/oozie/apps/DFE/queryGenerator-wf</app-path>
                    <configuration>
                            <property>
                                    <name>nameNode</name>
                                    <value>${nameNode}</value>
                            </property>
                            <property>
                                    <name>jobTracker</name>
                                    <value>${jobTracker}</value>
                            </property>

                    </configuration>
            </workflow>
    </action>
</coordinator-app>

如您所见，我将频率定义为 15 分钟，并发定义为 1。

但是，该作业每 5 分钟运行一次，它同时启动我的工作流的 4 个实例，如下面的屏幕截图所示：

Oozie 截图

我不明白为什么会这样，我真的很感激一些见解！

4

1 回答 1

4

在这种情况下，我想您的开始时间是过去的 - 如果您查看物化实例列，您会看到它们之间有 15 分钟的间隔。在开始时间过去的情况下，OOZIE 所做的是将所有任务有效地“回溯”到当前时间，相隔 5 分钟生成每个物化实例。

于 2013-11-08T02:41:36.813 回答