hadoop - MapReduce 与 Hadoop : Type mismatch in key from map

Question

我正在运行一个简单的 wordcount 程序，但出现以下错误:

Type mismatch in key from map: expected org.apache.hadoop.io.Text, received org.apache.hadoop.io.LongWritable

这是什么意思，我该如何纠正？

Answer 1

您可以在主函数中使用以下任一行:

 conf.setMapOutputKeyClass(Text.class);
 conf.setMapOutputValueClass(IntWritable.class);

假设您正在使用 JobConf conf；

或

    job.setMapOutputKeyClass(Text.class);
    job.setMapOutputValueClass(IntWritable.class);

假设您正在使用 Job job = new Job();