Hi ,  I used *old mapreduce API*  in oozie ,  it failed with :

Caused by: java.lang.RuntimeException: java.lang.RuntimeException: *class
VipTrackingMapper not org.apache.hadoop.mapred.Mapper*
at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2079)
at org.apache.hadoop.mapred.JobConf.getMapperClass(JobConf.java:1109)
at org.apache.hadoop.mapred.MapRunner.configure(MapRunner.java:38)



However, when I do the following setting :


*1. change mapred.mapper.class to  mapreduce.map.class2. set
mapred.mapper.new-api=false3. set mapred.reducer.new-api=false*
It  failed with :

Failing* Oozie Launcher, Main class
[org.apache.oozie.action.hadoop.MapReduceMain], main() threw exception,
mapreduce.job.map.class is incompatible with map compatability mode.*
  java.io.IOException: mapreduce.job.map.class is incompatible with map
compatability mode.
  at org.apache.hadoop.mapreduce.Job.ensureNotSet(Job.java:1199)
  at org.apache.hadoop.mapreduce.Job.setUseNewAPI(Job.java:1235)
  at org.apache.hadoop.mapreduce.Job.submit(Job.java:1288)
  at org.apache.hadoop.mapred.JobClient$1.run(JobClient.java:564)

*Is there any way can let  oozie support old mapreduce API ? thanks.*

Reply via email to