Мне нужно, чтобы получить пряжу 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, который я могу использовать.