Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MAPREDUCE-6079. Rename JobImpl#username to reporterUserName. Contributed by Tsuyoshi Ozawa.

This commit is contained in:
Akira Ajisaka 2015-05-08 18:16:58 +09:00
parent 888e630990
commit ecfa052274
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/CHANGES.txt
View File

@ -313,6 +313,9 @@ Release 2.8.0 - UNRELEASED
MAPREDUCE-6279. AM should explicity exit JVM after all services have MAPREDUCE-6279. AM should explicity exit JVM after all services have
stopped (Eric Payne via jlowe) stopped (Eric Payne via jlowe)
MAPREDUCE-6079. Rename JobImpl#username to reporterUserName.
(Tsuyoshi Ozawa via aajisaka)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

13
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/JobImpl.java
View File

@ -160,7 +160,7 @@ public class JobImpl implements org.apache.hadoop.mapreduce.v2.app.job.Job,
private final ApplicationAttemptId applicationAttemptId; private final ApplicationAttemptId applicationAttemptId;
private final Clock clock; private final Clock clock;
private final JobACLsManager aclsManager; private final JobACLsManager aclsManager;
private final String username; private final String reporterUserName;
private final Map<JobACL, AccessControlList> jobACLs; private final Map<JobACL, AccessControlList> jobACLs;
private float setupWeight = 0.05f; private float setupWeight = 0.05f;
private float cleanupWeight = 0.05f; private float cleanupWeight = 0.05f;
@ -688,7 +688,7 @@ public class JobImpl implements org.apache.hadoop.mapreduce.v2.app.job.Job,
this.jobTokenSecretManager = jobTokenSecretManager; this.jobTokenSecretManager = jobTokenSecretManager;
this.aclsManager = new JobACLsManager(conf); this.aclsManager = new JobACLsManager(conf);
this.username = System.getProperty("user.name"); this.reporterUserName = System.getProperty("user.name");
this.jobACLs = aclsManager.constructJobACLs(conf); this.jobACLs = aclsManager.constructJobACLs(conf);
ThreadFactory threadFactory = new ThreadFactoryBuilder() ThreadFactory threadFactory = new ThreadFactoryBuilder()
@ -868,13 +868,14 @@ public class JobImpl implements org.apache.hadoop.mapreduce.v2.app.job.Job,
} }
if (getInternalState() == JobStateInternal.NEW) { if (getInternalState() == JobStateInternal.NEW) {
return MRBuilderUtils.newJobReport(jobId, jobName, username, state, return MRBuilderUtils.newJobReport(jobId, jobName, reporterUserName,
appSubmitTime, startTime, finishTime, setupProgress, 0.0f, 0.0f, state, appSubmitTime, startTime, finishTime, setupProgress, 0.0f,
cleanupProgress, jobFile, amInfos, isUber, diagsb.toString()); 0.0f, cleanupProgress, jobFile, amInfos, isUber, diagsb.toString());
} }
computeProgress(); computeProgress();
JobReport report = MRBuilderUtils.newJobReport(jobId, jobName, username, JobReport report = MRBuilderUtils.newJobReport(jobId, jobName,
reporterUserName,
state, appSubmitTime, startTime, finishTime, setupProgress, state, appSubmitTime, startTime, finishTime, setupProgress,
this.mapProgress, this.reduceProgress, this.mapProgress, this.reduceProgress,
cleanupProgress, jobFile, amInfos, isUber, diagsb.toString()); cleanupProgress, jobFile, amInfos, isUber, diagsb.toString());