oozie协调器未按指定的频率间隔运行

6rvt4ljy  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(291)

我将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个示例,如下面的屏幕截图所示:

我不明白为什么会发生这种事,我真的很感激你的一些见解!

nwnhqdif

nwnhqdif1#

在本例中,我假设您的开始时间是在过去—如果您查看materialized instance列,您将看到它们之间有15分钟的间隔。在开始时间是过去的情况下,oozie所做的是,它将有效地将所有任务“向后调度”到当前时间,每5分钟生成一个物化示例。

相关问题