Pri spustení MapReduce čelím problémuprogram pomocou Hadoop 2 (YARN) a Pig. Dokážem čítať dáta z Cassandry pomocou Pig skriptu, avšak pri spustení MapReduce to vyvoláva výnimku, ako je uvedené nižšie:
Exception in thread "main" java.lang.IncompatibleClassChangeError: Found interface org.apache.hadoop.mapreduce.JobContext, but class was expected
at org.apache.cassandra.hadoop.ColumnFamilyOutputFormat.checkOutputSpecs(ColumnFamilyOutputFormat.java:80)
at org.apache.pig.newplan.logical.rules.InputOutputFileValidator$InputOutputFileVisitor.visit(InputOutputFileValidator.java:80)
at org.apache.pig.newplan.logical.relational.LOStore.accept(LOStore.java:66)
odpovede:
0 pre odpoveď č. 1Binárna distribúcia ošípaných je zostavená proti Hadoop 1.x. Ak chcete, aby fungoval, musíte ho prekompilovať proti 2.x (v mojom prípade 2.2). Skúste to:
ant clean jar-withouthadoop -Dhadoopversion=23
(zdroj)