我对hadoop很陌生。我正在尝试创建一个简单的mapreduce作业来查找实体的最大值。但是,我收到以下错误。
Error: java.io.IOException: Initialization of all the collectors failed. Error in last collector was :null
at org.apache.hadoop.mapred.MapTask.createSortingCollector(MapTask.java:414)
在另一个问题中,有人说这是因为映射器和reduce的值,但就我而言,这不是问题。映射器和减速器的定义如下
public static class MinimumMapper
extends Mapper<Object, Text, Text, IntWritable>{}
public static class MinimumReducer
extends Reducer<Text, IntWritable, Text, IntWritable> {}
有人知道原因吗?
请导入正确的文本类。
如果您导入了以下导入,则会收到该错误:
import com.sun.jersey.core.impl.provider.entity.XMLJAXBElementProvider.Text;
将其更改为此。
import org.apache.hadoop.io.Text;