Generic Запись данных не может быть приведен к Avro

Question

Я недавно запустить Sqoop работу, а затем использовали AvroTools для извлечения схемы из Avro файлов, а затем скомпилировать его в к класса Java. Всякий раз, когда я пытаюсь использовать Avro объект, я получаю следующее ClassCastException:

java.lang.Exception: java.lang.ClassCastException: org.apache.avro.generic.GenericData $ Запись не может быть приведен к com.xxx.xxx.patient_avro.PatientAvro на org.apache.hadoop.mapred.LocalJobRunner $ Job.runTasks (LocalJobRunner.java:462) в org.apache.hadoop.mapred.LocalJobRunner $ Job.run (LocalJobRunner. java: 522) Вызвано: java.lang.ClassCastException: org.apache.avro.generic.GenericData $ Запись не может быть отлита до com.xxx.xxx.patient_avro.PatientAvro at c om.xxx.xxx.knn_mapreduce.KNNMapper.map (KNNMapper.java:28) в com.xxx.xxx.knn_mapreduce.KNNMapper.map (KNNMapper.java:14) в org.apache.hadoop.mapreduce.Mapper. (Mapper.java:146) в org.apache.hadoop.mapred.MapTask.runNewMapper (MapTask.java:787) в org.apache.hadoop. mapred.MapTask.run (MapTask.java:341)

Мой Mapper:

public class KNNMapper extends Mapper<AvroKey<PatientAvro>, NullWritable, LongWritable, PatientWritable> { 

PatientWritable patient; 
LongWritable providerKey; 
Integer patientKey; 
Integer lengthOfStay; 
Integer msDrgGroup; 
Integer age; 

@Override 
public void map(AvroKey<PatientAvro> patientAvro, NullWritable value, Context context) throws IOException, InterruptedException { 



    patientKey = patientAvro.datum().getPatientKey(); 
    lengthOfStay = patientAvro.datum().getLengthOfStay(); 
    msDrgGroup = patientAvro.datum().getMsDrg(); 
    age = patientAvro.datum().getAge(); 
    patient = new PatientWritable(); 
    patient.set(new Long(patientKey), new Double((double) lengthOfStay), new Double((double) msDrgGroup), new Double((double)age)); 

    providerKey = new LongWritable(patientAvro.datum().getProviderKey()); 
    context.write(providerKey, patient); 
} 
} 

Любая помощь будет принята с благодарностью.

Answer 1

Sqoop автоматически создает файлы Java и .avsc. Вы создаете их отдельно ?. Поэтому, если вы просто используете сгенерированную Java, вы должны быть в порядке.