WORDCOUNT程序上的hadoop错误

Question

 html" target="_blank">public static void main(String[] args) throws Exception 
 {
    Configuration conf = new Configuration();
    conf.addResource(new Path("/usr/local/hadoop/etc/hadoop/core-site.xml"));
    conf.addResource(new Path("/usr/local/hadoop/etc/hadoop/hdfs-site.xml"));
    Job job = new Job();
    //job.setJarByClass(WordCount.class);
    job.setJobName("WordCounter");

    job.setJarByClass(WordCount.class);
    job.setMapperClass(TokenizerMapper.class);
    job.setCombinerClass(IntSumReducer.class);
    job.setReducerClass(IntSumReducer.class);
    job.setOutputKeyClass(Text.class);
    job.setOutputValueClass(IntWritable.class);
    FileInputFormat.addInputPath(job, new Path("/home/pramukh/eclipse/eclipseproj/hadoop/input/input.txt"));
    FileOutputFormat.setOutputPath(job, new Path("/home/pramukh/eclipse/eclipseproj/hadoop/output.txt"));
//System.exit(0);
    System.exit(job.waitForCompletion(true) ? 0 : 1);
  }

这是我的java hadoop wordcount示例，它给出了以下错误：

线程“main”java.lang.noClassDeffounderRror：org/apache/avro/io/DatumReader在java.lang.class.forName0（本机方法）在java.lang.class.forName(class.java:348)在org.apache.hadoop.io.serializer.serializationFactor.getClassByName（配置.java:1074)在org.apache.hadoop.io.serializer.serializationFactor.add(SerializationFactor.69)在在javax.security.auth.subject.doas（subject.java:422)在org.apache.hadoop.security.usergroupinformation.doas（usergroupinformation.java:742)在org.apache.hadoop.mapred.jobclient.submitjobinternal（jobclient.java:912)在org.apache.hadoop.mapreduce.job.submit（job.java:500)在org.apache.hadoop.mapreduce.job.submit（

提前道谢。

Answer 1

如果您在此程序中的其余代码被更正；我建议您检查OutputPath文件夹不能存在的路径
我尝试了您的代码更改文件路径，代码可以正常运行

FileInputFormat.addInputPath(job, new Path("hdfs://localhost:9000/wordcount/test.txt"));
    FileOutputFormat.setOutputPath(job, new Path("hdfs://localhost:9000/wordcount/out"));