今天写了一个MapReduce程序,报错如下: Type mismatch in value from map: expected org.apache.hadoop.io.FloatWritable, received org.apache.hadoop.io.LongWritable。
知道这是设置的Map输出和配置的不匹配错误。
找了一下,发现是:
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(FloatWritable.class);