2017-01-13 9 views
0

Мне нужно, чтобы получить пряжу applicationId из задания mapreduce. Я не могу найти API для этого. Пример моей MapReduce работы:Получить пряжу applicationId с предоставленной заданием mapreduce

Configuration conf = new Configuration(); 
Job job = Job.getInstance(conf, "word count"); 
job.setJarByClass(WordCount.class); 
job.setMapperClass(TokenizerMapper.class); 
job.setCombinerClass(IntSumReducer.class); 
job.setReducerClass(IntSumReducer.class); 
job.setOutputKeyClass(Text.class); 
job.setOutputValueClass(IntWritable.class); 
FileInputFormat.addInputPath(job, new Path(args[0])); 
FileOutputFormat.setOutputPath(job, new Path(args[1])); 
job.submit(); 
job.waitForCompletion(true); 

Есть ли API похож на job.getJobId для получения пряжи ApplicationID? Я знаю о команде yarn application -list, но мне нужно знать приложение в моей программе через какой-то API. Похоже, что jobId такой же, как applicationId execpt для префикса ('job' vs 'application'), который я мог бы анализировать, но я надеюсь, что есть что-то из API, который я могу использовать.

ответ

1

Я закончил синтаксический анализ jobId, удалив префикс 'job' и добавив префикс 'application', поскольку он появляется applicationId не отображается для задания mapreduce, и это в основном тот же идентификатор, что и jobId с другим префиксом. Это взломанный подход, но работает пока.

 Смежные вопросы

  • Нет связанных вопросов^_^