workflow.xml

<workflow-app xmlns='xmlns=uri:oozie:workflow:0.1' name='oozie_flow'>
  <start to='ingestor' />
  <action name='ingestor'>
    <java>
      <job-tracker>${jobTracker}</job-tracker>
      <name-node>${nameNode}</name-node>
      <configuration>
        <property>
          <name>mapred.job.queue.name</name>
          <value>default</value>
        </property>
      </configuration>
      <main-class>com.navteq.assetmgmt.MapReduce.ips.IPSLoader</main-class>
      <arg>${driveID}</arg>
    </java>
    <ok to='merging' />
    <error to='fail' />
  </action>
  <fork name='merging'>
    <path start='mergeLidar' />
    <path start='mergeSignage' />
  </fork>
  <action name='mergeLidar'>
    <java>
      <job-tracker>${jobTracker}</job-tracker>
      <name-node>${nameNode}</name-node>
      <configuration>
        <property>
          <name>mapred.job.queue.name</name>
          <value>default</value>
        </property>
      </configuration>
      <main-class>com.navteq.assetmgmt.hdfs.merge.MergerLoader</main-class>
      <java-opts>-Xmx2048m</java-opts>
      <arg>-drive</arg>
      <arg>${driveID}</arg>
      <arg>-type</arg>
      <arg>Lidar</arg>
      <arg>-chunk</arg>
      <arg>${lidarChunk}</arg>
    </java>
    <ok to='completed' />
    <error to='fail' />
  </action>
  <action name='mergeSignage'>
    <java>
      <job-tracker>${jobTracker}</job-tracker>
      <name-node>${nameNode}</name-node>
      <configuration>
        <property>
          <name>mapred.job.queue.name</name>
          <value>default</value>
        </property>
      </configuration>
      <main-class>com.navteq.assetmgmt.hdfs.merge.MergerLoader</main-class>
      <java-opts>-Xmx2048m</java-opts>
      <arg>-drive</arg>
      <arg>${driveID}</arg>
      <arg>-type</arg>
      <arg>Lidar</arg>
      <arg>-chunk</arg>
      <arg>${signageChunk}</arg>
    </java>
    <ok to='completed' />
    <error to='fail' />
  </action>
  <kill name='fail'>
    <message>Java failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
  </kill>
  <join name='completed' to='end' />
  <end name='end' />
</workflow-app>