免费注册
帮助文档(华北一、二)

  • 先看一下官方发行包自带的一个简单例子 oozie/examples/src/main/apps/cron。它能够实现定时调度一个工作流Job运行,这个例子中给出的一个空的工作流Job,也是为了演示能够使用Coordinator系统给调度起来。

    点击下载oozie-example.tar.gz

    这个例子有3个配置文件。修改后分别如下所示:

    ● job.properties配置

     

    nameNode=hdfs://uhadoop-XXXXXX-master1:8020

    jobTracker=uhadoop-XXXXXX-master1:23140

    queueName=default

    examplesRoot=examples

    oozie.coord.application.path=${nameNode}/user/${user.name}/${examplesRoot}/apps/cron

    start=2016-12-01T19:00Z

    end=2016-12-31T01:00Z

    workflowAppUri=${nameNode}/user/${user.name}/${examplesRoot}/apps/cron

    修改了Hadoop集群的配置,以及调度起止时间范围。

    ● wordflow.xml

     

    <workflow-app xmlns="uri:oozie:workflow:0.5" name="one-op-wf">

        <start to="action1"/>

    <action name="action1">

           <fs/>

        <ok to="end"/>

        <error to="end"/>

        </action>

        <end name="end"/>

    </workflow-app>

    这是一个空Job,没做任何修改。

    ● corrdinator.xml配置

     

    <coordinator-app name="cron-coord" frequency="${coord:minutes(2)}" start="${start}" end="${end}" timezone="UTC" xmlns="uri:oozie:coordinator:0.2">

         <action>

              <workflow>

                   <app-path>${workflowAppUri}</app-path>

                   <configuration>

                        <property>

                             <name>jobTracker</name>

                             <value>${jobTracker}</value>

                        </property>

                        <property>

                             <name>nameNode</name>