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

YARN-4130. Duplicate declaration of ApplicationId in RMAppManager#submitApplication method. (Kai Sasaki via rohithsharmaks)

This commit is contained in:
Rohith Sharma K S 2015-10-29 12:22:44 +05:30
parent 07ecdb877d
commit 656c8f9527
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1031,6 +1031,9 @@ Release 2.8.0 - UNRELEASED
YARN-4251. TestAMRMClientOnRMRestart#testAMRMClientOnAMRMTokenRollOverOnRMRestart YARN-4251. TestAMRMClientOnRMRestart#testAMRMClientOnAMRMTokenRollOverOnRMRestart
is failing. (Brahma Reddy Battula via ozawa) is failing. (Brahma Reddy Battula via ozawa)
YARN-4130. Duplicate declaration of ApplicationId in RMAppManager#submitApplication method.
(Kai Sasaki via rohithsharmaks)
Release 2.7.2 - UNRELEASED Release 2.7.2 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

8
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java
View File

@ -281,14 +281,14 @@ public class RMAppManager implements EventHandler<RMAppManagerEvent>,
RMAppImpl application = RMAppImpl application =
createAndPopulateNewRMApp(submissionContext, submitTime, user, false); createAndPopulateNewRMApp(submissionContext, submitTime, user, false);
ApplicationId appId = submissionContext.getApplicationId();
Credentials credentials = null; Credentials credentials = null;
try { try {
credentials = parseCredentials(submissionContext); credentials = parseCredentials(submissionContext);
if (UserGroupInformation.isSecurityEnabled()) { if (UserGroupInformation.isSecurityEnabled()) {
this.rmContext.getDelegationTokenRenewer().addApplicationAsync(appId, this.rmContext.getDelegationTokenRenewer()
credentials, submissionContext.getCancelTokensWhenComplete(), .addApplicationAsync(applicationId, credentials,
application.getUser()); submissionContext.getCancelTokensWhenComplete(),
application.getUser());
} else { } else {
// Dispatcher is not yet started at this time, so these START events // Dispatcher is not yet started at this time, so these START events
// enqueued should be guaranteed to be first processed when dispatcher // enqueued should be guaranteed to be first processed when dispatcher