Исключение при отправке задания maprecece из удаленной системы
Я получил исключение при отправке задания mapreduce из удаленной системы
13/10/28 18:49:52 ОШИБКА security.UserGroupInformation: PriviledgedActionException as: корневая причина: org.apache.hadoop.mapred.InvalidInputException: Путь ввода не существует: файл: / F: / рабочие пространства / Test / Hadoop / test
Моя среда hadoop и mapreduce настроена на машине с Linux. Я отправляю задание wordcount с локального ПК с Windows следующим образом:
public static void main(String[] args) throws Exception {
UserGroupInformation ugi = UserGroupInformation.createRemoteUser("root");
try {
ugi.doAs(new PrivilegedExceptionAction<Void>() {
public Void run() throws Exception {
JobConf conf = new JobConf(MapReduce.class);
conf.set("mapred.job.name", "MyApp");
conf.set("mapred.job.tracker", "192.168.1.149:9001");
conf.set("fs.default.name","hdfs://192.168.1.149:9000");
conf.set("hadoop.job.ugi", "root");
conf.setOutputKeyClass(Text.class);
conf.setOutputValueClass(IntWritable.class);
conf.setMapperClass(Map.class);
conf.setCombinerClass(Reduce.class);
conf.setReducerClass(Reduce.class);
conf.setInputFormat(TextInputFormat.class);
conf.setOutputFormat(TextOutputFormat.class);
FileInputFormat.setInputPaths(conf, new Path("test"));
FileOutputFormat.setOutputPath(conf, new Path("test"));
JobClient.runJob(conf);
return null;
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
где 192.168.1.149 - это сконфигурированный на Linux ПК linux. Я начал hadoop, сервисы mapreduce там. Такжеконтрольная работа каталог был также создан с тем же API Java, он работал. Но mapreduce нет.
**Пожалуйста помоги .. **