java.lang.IncompatibleClassChangeError: Found class org.apache.hadoop.mapreduce.JobContext, but inte

[Jerry MJ]

I started camus at an older version and it worked nicely locally and on cluster.

Recently, I did a sync-up with the master on github and pulled down lots of changes.  With some minimal changes in the code, I am able to rebuild my jar.  After the re-build of the jar, the job still runs successfully with local mode, however, it starts to give me hard time when I run it on cluster.  Any one got any similar experience?

Exception I got is here.

Exception in thread "main" java.lang.IncompatibleClassChangeError: Found class org.apache.hadoop.mapreduce.JobContext, but interface was expected

at com.linkedin.camus.etl.kafka.CamusJob.getLog4jConfigure(CamusJob.java:743)

at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:247)

at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:235)

at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:691)

at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)

at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:79)

at com.linkedin.camus.etl.kafka.CamusJob.main(CamusJob.java:646)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)

at java.lang.reflect.Method.invoke(Unknown Source)

at org.apache.hadoop.util.RunJar.main(RunJar.java:197)