xml

<workflow-app xmlns="uri:oozie:workflow:0.1" name="WordCountTest">
<start to="intersection0" />
<action name="intersection0">
  <map-reduce>
    <job-tracker>quickstart.cloudera:8032</job-tracker>
    <name-node>hdfs://quickstart.cloudera:8020</name-node>
    <prepare>
      <delete path="hdfs://localhost:8020/user/cloudera/coba/innerJoin/out"/>
    </prepare>
    <configuration>
      <property>
        <name>mapred.job.queue.name</name>
        <value>default</value>
      </property>
        <property>
          <name>mapred.mapper.new-api</name>
          <value>true</value>
        </property>
        <property>
          <name>mapred.reducer.new-api</name>
          <value>true</value>
        </property>
      <property>
        <name>mapreduce.map.class</name>
        <value>org.apache.hadoop.mapreduce.lib.input.DelegatingMapper</value>
      </property>
      <property>
        <name>mapreduce.reduce.class</name>
        <value>edu.stts.bigdata.InnerJoinReducer</value>
      </property>
      <property>
        <name>mapred.output.key.class</name>
        <value>org.apache.hadoop.io.Text</value>
      </property>
      <property>
        <name>mapred.output.value.class</name>
        <value>org.apache.hadoop.io.Text</value>
      </property>
      <property>
        <name>mapreduce.inputformat.class</name>
        <value>org.apache.hadoop.mapreduce.lib.input.DelegatingInputFormat</value>
      </property>
      <property>
        <name>mapred.outputformat.class</name>
        <value>org.apache.hadoop.mapreduce.lib.output.TextOutputFormat</value>
      </property>
      <property>
        <name>mapreduce.input.multipleinputs.dir.formats</name>
        <value>/user/cloudera/innerJoin/in;org.apache.hadoop.mapreduce.lib.input.TextInputFormat,/user/cloudera/innerJoin/in2;org.apache.hadoop.mapreduce.lib.input.TextInputFormat</value>
      </property>
      <property>
        <name>mapreduce.input.multipleinputs.dir.mappers</name>
        <value>/user/cloudera/innerJoin/in;edu.stts.bigdata.CustomerMapper,/user/cloudera/innerJoin/in2;edu.stts.bigdata.OrderMapper</value>
      </property>
      <property>
        <name>mapred.output.dir</name>
        <value>/user/cloudera/innerJoin/out</value>
      </property>
    </configuration>
  </map-reduce>
  <ok to="end"/>
  <error to="fail" />
</action>
<kill name="fail" >
  <message>Map/Reduce Failed</message>
</kill>
<end name="end" />
</workflow-app>