при запуске программы mapreduce на кластере входной путь считался выходным путем - PullRequest
1 голос
/ 09 июня 2019

Когда я запускаю программу map-Reduce в кластере, входной путь рассматривается как выходной путь, поэтому я всегда получаю сообщение об ошибке:

выходной каталог уже существует.

Но когда я игнорирую аргументы DriverClass, программа запускается успешно.Я действительно не знаю, почему это произошло.И я могу запустить эту программу в IntelliJ IDEA, я получаю правильный ответ в локальной среде.

Я не ошибся с индексом входного пути и выходной

FileInputFormat.setInputPaths(job,new Path(args[0]));
FileOutputFormat.setOutputPath(job,new Path(args[1]));

HDFS структурой

enter image description here

и мои сообщения об ошибках и команда hadoop ниже

enter image description here

, нопосле того, как я проигнорировал аргументы DriverClass, программа успешно запустилась

enter image description here

1 Ответ

0 голосов
/ 10 июня 2019

Ваша проблема с:

FileInputFormat.setInputPaths(job,new Path(args[0]));
FileOutputFormat.setOutputPath(job,new Path(args[1]));

args[0] на самом деле является именем класса, поэтому вы хотите использовать args[1] для ввода и args[2] для вывода.

...