2016-06-08 1 views
0

나는 상당히 새로운 경험이 있습니다. 엔티티의 최대 값을 찾기 위해 간단한 mapreduce 작업을 만들려고합니다. 그러나 나는 아래 오류가 나타납니다.모든 수집기의 Hadoop 초기화가 실패했습니다. 마지막 수집기에 오류가있었습니다 : null

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) 

누군가 다른 사람이 말하기를 이것이 매퍼의 가치 때문이라고 말했지만 내 경우에는 문제가되지 않습니다. 매퍼 및 감속기의 정의는 다음과 같습니다.

public static class MinimumMapper 
    extends Mapper<Object, Text, Text, IntWritable>{} 

public static class MinimumReducer 
    extends Reducer<Text, IntWritable, Text, IntWritable> {} 

이유에 대한 단서가 있습니까?

답변

0

올바른 Text 클래스를 가져 오십시오. 당신이 아래의 수입을 가져온 경우

해당 오류가 발생합니다 : 이것에

import com.sun.jersey.core.impl.provider.entity.XMLJAXBElementProvider.Text; 

변경을.

import org.apache.hadoop.io.Text; 
관련 문제