hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jh...@apache.org
Subject [44/50] [abbrv] hadoop git commit: MAPREDUCE-6852. Job#updateStatus() failed with NPE due to race condition. Contributed by Junping Du
Date Fri, 03 Mar 2017 02:45:55 GMT
MAPREDUCE-6852. Job#updateStatus() failed with NPE due to race condition. Contributed by Junping
Du


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/747bafaf
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/747bafaf
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/747bafaf

Branch: refs/heads/YARN-5734
Commit: 747bafaf969857b66233a8b4660590bdd712ed7d
Parents: eeca8b0
Author: Jian He <jianhe@apache.org>
Authored: Thu Mar 2 10:58:56 2017 -0800
Committer: Jian He <jianhe@apache.org>
Committed: Thu Mar 2 10:58:56 2017 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/mapreduce/Job.java             | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/747bafaf/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java
----------------------------------------------------------------------
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 45c065d..84d90de 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<JobStatus>() {
         @Override
         public JobStatus run() throws IOException, InterruptedException {
-          return cluster.getClient().getJobStatus(status.getJobID());
+          return cluster.getClient().getJobStatus(getJobID());
         }
       });
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message