Skip to content

Instantly share code, notes, and snippets.

@rclayton-the-terrible
Created February 4, 2012 20:19
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save rclayton-the-terrible/1739874 to your computer and use it in GitHub Desktop.
Save rclayton-the-terrible/1739874 to your computer and use it in GitHub Desktop.
Oozie Workflow
<workflow-app name='example' xmlns="uri:oozie:workflow:0.1">
<start to='firstjob' />
<action name="firstjob">
<map-reduce>
<job-tracker>${jobtracker}</job-tracker>
<name-node>${namenode}</name-node>
<configuration>
<property><name>mapred.mapper.class</name><value>org.apache.hadoop.example.IdMapper</value></property>
<property><name>mapred.reducer.class</name><value>org.apache.hadoop.example.IdReducer</value></property>
<property><name>mapred.map.tasks</name><value>1</value></property>
<property><name>mapred.input.dir</name><value>${input}</value></property>
<property><name>mapred.output.dir</name><value>/usr/foo/${wf:id()}/temp1</value></property>
</configuration>
</map-reduce>
<ok to="end" />
<error to="kill" />
</action>
<kill name="kill">
<message>Map/Reduce failed, error message[${wf:errorMessage()}]</message>
</kill>
<end name='end'/>
</workflow-app>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment