Почему не работает?

public class IntSumReducer extends Reducer<Text,Text,Text,IntWritable> {
   private IntWritable result = new IntWritable();
   public void reduce(Text key, Text values, Context context) throws IOException, InterruptedException {
   String[] items = values.split(";");
   int a = Integer.parseInt(items[0], 10);
   int b = Integer.parseInt(items[1], 10);
   int c = Integer.parseInt(items[2], 10);
   int sum = (2 * a * b) * Math.abs(c + (4 * a));
 result.set(sum);
 context.write(key, result);
   }
}

Результат map правильный

Text.split точно строки возвращает?
а вообще отлично отдебажить можно принтами) принтани что ты парсишь

parseInt чувситвельная функция; отсутпы пробелы не уберешь - Оно ничего не распарсит

это кстати файл part-r- , судя по "r" он все-таки прошел reduce?

да; r редьюсеры плодят

принтани что ты пишешь в результат

интересно)

system.out.println? А куда выводится? В консоли не видно

может быть надо строку добавить от себя, вдруг там пустоту возвращает

а ты как сабмитишь Джобы?

в консоли командой hadoop jar и т.д.

по-моему можно посмотреть тут
http://localhost:50030/jobtracker.jsp

принты туда валятся

ок

не открывается. Но вот такое нашел в YARN. Тут можно наверное смотреть лог?

Тыкай по Хистори

И там уже будут логи и по мэперу и по редьюсеру, но вообще

https://www.infoq.com/articles/HadoopMRUnit/

Насколько помню уже в хадупе для юнит тестов запуск и сабмит в in jvm мод есть, там же и брекпоинты можешь ставить