merge -r 1346001:1346002 from trunk. FIXES: MAPREDUCE-4301
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1346003 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
8960db7605
commit
c59349ede3
|
@ -261,6 +261,9 @@ Release 0.23.3 - UNRELEASED
|
|||
|
||||
MAPREDUCE-4162. Correctly set token service (Daryn Sharp via bobby)
|
||||
|
||||
MAPREDUCE-4301. Dedupe some strings in MRAM for memory savings
|
||||
(bobby via tgraves)
|
||||
|
||||
OPTIMIZATIONS
|
||||
|
||||
MAPREDUCE-3850. Avoid redundant calls for tokens in TokenCache (Daryn
|
||||
|
|
|
@ -47,6 +47,7 @@ public class SplitMetaInfoReader {
|
|||
long maxMetaInfoSize = conf.getLong(JTConfig.JT_MAX_JOB_SPLIT_METAINFO_SIZE,
|
||||
10000000L);
|
||||
Path metaSplitFile = JobSubmissionFiles.getJobSplitMetaFile(jobSubmitDir);
|
||||
String jobSplitFile = JobSubmissionFiles.getJobSplitFile(jobSubmitDir).toString();
|
||||
FileStatus fStatus = fs.getFileStatus(metaSplitFile);
|
||||
if (maxMetaInfoSize > 0 && fStatus.getLen() > maxMetaInfoSize) {
|
||||
throw new IOException("Split metadata size exceeded " +
|
||||
|
@ -70,7 +71,7 @@ public class SplitMetaInfoReader {
|
|||
JobSplit.SplitMetaInfo splitMetaInfo = new JobSplit.SplitMetaInfo();
|
||||
splitMetaInfo.readFields(in);
|
||||
JobSplit.TaskSplitIndex splitIndex = new JobSplit.TaskSplitIndex(
|
||||
JobSubmissionFiles.getJobSplitFile(jobSubmitDir).toString(),
|
||||
jobSplitFile,
|
||||
splitMetaInfo.getStartOffset());
|
||||
allSplitMetaInfo[i] = new JobSplit.TaskSplitMetaInfo(splitIndex,
|
||||
splitMetaInfo.getLocations(),
|
||||
|
|
Loading…
Reference in New Issue