Resource Leaks in key flows
---------------------------
Key: MAPREDUCE-3556
URL: https://issues.apache.org/jira/browse/MAPREDUCE-3556
Project: Hadoop Map/Reduce
Issue Type: Bug
Affects Versions: 0.23.0
Reporter: Devaraj K
Assignee: Devaraj K
{code:title=MapTask.java|borderStyle=solid}
{code}
{code:xml}
if (combinerRunner == null || numSpills < minSpillsForCombine) {
Merger.writeFile(kvIter, writer, reporter, job);
} else {
combineCollector.setWriter(writer);
combinerRunner.combine(kvIter, combineCollector);
}
//close
writer.close();
{code}
{code:title=InputSampler.java|borderStyle=solid}
{code}
{code:xml}
for(int i = 1; i < numPartitions; ++i) {
int k = Math.round(stepSize * i);
while (last >= k && comparator.compare(samples[last], samples[k]) == 0) {
++k;
}
writer.append(samples[k], nullValue);
last = k;
}
writer.close();{code}
The key flows have potential resource leaks.
{code:title=JobSplitWriter.java|borderStyle=solid}
{code}
{code:xml}
SplitMetaInfo[] info = writeNewSplits(conf, splits, out);
out.close();
SplitMetaInfo[] info = writeOldSplits(splits, out);
out.close();
{code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira