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)