Getting existing mapreduce job from cluster (the job could be running or completed)
You look for getAllJobStatuses() that return JobStatus[]:
List<JobStatus> runningJobs = new ArrayList<JobStatus>(); List<JobStatus> completedJobs = new ArrayList<JobStatus>(); for (JobStatus job : cluster.getAllJobStatuses()) { if (!job.isJobComplete()) { runningJobs.add(job); } else { completedJobs.add(job) } } // list of running JobIDs for (JobStatus rjob : runningJobs) { System.out.println(rjob.getJobID().toString()); } // list of completed JobIDs for (JobStatus cjob : completedJobs) { System.out.println(cjob.getJobID().toString()); } // to print out short report on running jobs: // displayJobList(runningJobs.toArray(new JobStatus[0]));