diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java index 45c065da5e4..84d90deff6f 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java @@ -323,7 +323,7 @@ public class Job extends JobContextImpl implements JobContext { this.status = ugi.doAs(new PrivilegedExceptionAction() { @Override public JobStatus run() throws IOException, InterruptedException { - return cluster.getClient().getJobStatus(status.getJobID()); + return cluster.getClient().getJobStatus(getJobID()); } }); }