我正在尝试使用avro运行mapreduce，但是在尝试了网络上人们建议的所有选项之后，我仍然无法通过-15/11/0921:54:48警告mapred.LocalJobRunner:job_local1421922570_0001java.lang.Exception:java.lang.NoSuchMethodError:org.apache.avro.generic.GenericData.createDatumWriter(Lorg/apache/avro/Schema;)Lorg/apache/avro/io/DatumWriter;下面是代码(来自Hadoop权威指南)pu

我所有的程序都是用hadoop的新MR1接口(interface)(org.apache.hadoop.mapreduce)编写的，所以我也想使用avro的新org.apache.avro.mapreduce。但这对我不起作用。该程序接受avro数据的输入并输出相同的数据。我的程序背后的主要思想是根据avro包装的键/值对hadoop的Mapper和Reducer进行子类化。这是我的工作驱动程序的一部分:AvroJob.setInputKeySchema(job,NetflowRecord.getClassSchema());AvroJob.setOutputKeySchema(job

我正在将一个hadoop作业的avro输出提供给另一个hadoop作业。第一项工作仅运行具有以下设置的映射器。如果它有任何用处，我的avsc文件定义了一个复合对象，如下所示:[{"type":"record","name":"MySubRecord","namespace":"blah","fields":[{"name":"foobar","type":["null","string"],"default":null},{"name":"bar","type":["null","string"],"default":null},{"name":"foo","type":["null"