MAPREDUCE-3233. Fixed a bug in MR Job so as to be able to restart the application on AM crash. Contributed by Mahadev Konar.
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1187669 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
665a90cbf3
commit
977d7cc5b9
|
@ -1735,6 +1735,9 @@ Release 0.23.0 - Unreleased
|
||||||
MAPREDUCE-3087. Fixed the mapreduce classpath to correctly include the
|
MAPREDUCE-3087. Fixed the mapreduce classpath to correctly include the
|
||||||
generated-classpath file needed for tests. (Ravi Prakash via vinodkv)
|
generated-classpath file needed for tests. (Ravi Prakash via vinodkv)
|
||||||
|
|
||||||
|
MAPREDUCE-3233. Fixed a bug in MR Job so as to be able to restart the
|
||||||
|
application on AM crash. (Mahadev Konar via vinodkv)
|
||||||
|
|
||||||
Release 0.22.0 - Unreleased
|
Release 0.22.0 - Unreleased
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -1044,13 +1044,6 @@ public class JobImpl implements org.apache.hadoop.mapreduce.v2.app.job.Job,
|
||||||
if (UserGroupInformation.isSecurityEnabled()) {
|
if (UserGroupInformation.isSecurityEnabled()) {
|
||||||
tokenStorage.addAll(job.fsTokens);
|
tokenStorage.addAll(job.fsTokens);
|
||||||
}
|
}
|
||||||
|
|
||||||
Path remoteJobTokenFile =
|
|
||||||
new Path(job.remoteJobSubmitDir,
|
|
||||||
MRJobConfig.APPLICATION_TOKENS_FILE);
|
|
||||||
tokenStorage.writeTokenStorageFile(remoteJobTokenFile, job.conf);
|
|
||||||
LOG.info("Writing back the job-token file on the remote file system:"
|
|
||||||
+ remoteJobTokenFile.toString());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in New Issue