Я пытаюсь запустить работу по сокращению карты на карте Amazon уменьшить кластер. Моя работа по сокращению карты выполняет некоторую предварительную обработку, прежде чем создавать задачи по карте/сок
У меня есть свой картер и редукторы следующим образом. Но я получаю странное исключение. Я не могу понять, почему он бросает такое исключение. public static class MyMapper implements Mapper<LongWritab
Я создаю свой собственный редуктор следующим образом: public class MyReducer implemts Reducer<K1,V1,K2,V2>{
@override
public void configure(JobConf conf){
}
@override
public void close(JobConf
Я написал Mapper и Reducer в Python и успешно выполнил его на Elastic MapReduce (EMR) Amazon, используя Hadoop Streaming. Папка конечного результата содержит выход в трех разных файлах part-00000, par