我将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个示例,如下面的屏幕截图所示:
我不明白为什么会发生这种事,我真的很感激你的一些见解!
1条答案
按热度按时间nwnhqdif1#
在本例中,我假设您的开始时间是在过去—如果您查看materialized instance列,您将看到它们之间有15分钟的间隔。在开始时间是过去的情况下,oozie所做的是,它将有效地将所有任务“向后调度”到当前时间,每5分钟生成一个物化示例。