[jira] [Updated] (MAPREDUCE-3556) Resource Leaks in key flows

["Devaraj K (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/MAPREDUCE-3556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Devaraj K updated MAPREDUCE-3556:
---------------------------------

    Resolution: Won't Fix
        Status: Resolved  (was: Patch Available)
    
> 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
>         Attachments: MAPREDUCE-3556.patch
>
>
> {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
For more information on JIRA, see: http://www.atlassian.com/software/jira