java - MapReduce 以编程方式获取当前作业 ID

Question

我给予之后JobClient.runJob(jobConf)

如何获取该MapReduce任务的JobID？

我见过下面这样的代码，但它返回所有当前正在运行的作业 ID

System.out.println("Printing job IDs...");
JobClient client = new JobClient(jobConf);
JobStatus[] status = client.getAllJobs();
for(int i = 0; i < status.length; i++){
    if(!status[i].isJobComplete()){
        JobID jobid = status[i].getJobID();
        System.out.println(jobid.toString());
    }
}

更新:

好吧，我忽略了一些事情。 runJob 方法返回一个 RunningJob 对象，该对象具有 getID 方法。但 RunningJob 对象仅在作业完成运行后才会返回。有没有办法在作业仍在运行时获取 ID？

RunningJob currentJob = JobClient.runJob(jobConf);  
System.out.println("JobID: " + currentJob.getID().toString());

Answer 1

SubmitJob 似乎可以解决问题。

JobClient client = new JobClient(jobConf);
RunningJob currentJob = client.submitJob(jobConf);
System.out.println("JobID: " + currentJob.getID().toString());