我有一个oozie协调员和工作流作业,当我的一个工作流操作完成后,我需要在一段时间后开始下一个操作,比如说50分钟。我可以从oozie工作流或oozie协调器配置它,以等待一段时间来执行下一个操作(取决于上一个操作和上一个操作启动的一些异步任务)。
协调器xml
<coordinator-app name="ods-ds-cms-coordinator" start="${startTime}" end="${endTime}"
frequency="${coord:days(1)}" timezone="${timeZone}" xmlns="uri:oozie:coordinator:0.5">
<action>
<workflow>
<app-path>${exampleDir}/ods-ds-cms-workflow.workflow</app-path>
<configuration>
<property>
<name>nameNode</name>
<value>${nameNode}</value>
</property>
<property>
<name>jobTracker</name>
<value>${jobTracker}</value>
</property>
<property>
<name>exampleDir</name>
<value>${nameNode}/custom/oozie</value>
</property>
</configuration>
</workflow>
</action>
</coordinator-app>
工作流.xml
<?xml version="1.0" encoding="UTF-8"?>
<workflow-app xmlns="uri:oozie:workflow:0.5" name="ods-ds-cms-workflow.workflow">
<global>
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<configuration>
<property>
<name>mapred.job.queue.name</name>
<value>${queue}</value>
</property>
</configuration>
</global>
<start to="cms-checker"/>
<action name="cms-checker">
<java>
<main-class>com.insense.helper.CMSPullChecker</main-class>
<arg>${cmsChecker}</arg>
<arg>${cmsType}</arg>
<capture-output/>
</java>
<ok to="trigger_next_job"/>
<error to="kill"/>
</action>
<action name="trigger_next_job"> // need to start this after some time
<sub-workflow>
<app-path>${exampleDir}/ods-ds-bank.workflow</app-path>
<propagate-configuration/>
</sub-workflow>
<ok to="end"/>
<error to="kill"/>
</action>
如何用oozie framwork存档,我可以用java action和thread.sleep(50601000)来实现,这是用oozie更好的方法吗?
1条答案
按热度按时间bttbmeg01#
您可以使用一个作业shell作业创建另一个工作流。然后您应该使用一个命令创建shell脚本:
当一个工作流将完成时,您应该使用
sleep
命令。下一个工作流将在50分钟后启动。例子。
工作流.xml
睡眠.sh