[MAPREDUCE-5865] RecordReader is not closed in TeraInputFormat#writePartitionFile()

• Type: Bug
• Status: Patch Available
• Priority: Major
• Resolution: Unresolved
• Component/s: mrv1
• Labels: BB2015-05-TBR
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 28/Apr/14 17:20
• Updated: 10/Mar/17 02:25

Description

Here is related code:

            RecordReader<Text, Text> reader = 
              inFormat.createRecordReader(splits.get(sampleStep * idx),
              context);
            reader.initialize(splits.get(sampleStep * idx), context);
            while (reader.nextKeyValue()) {
              sampler.addKey(new Text(reader.getCurrentKey()));
              records += 1;
              if (recordsPerSample <= records) {
                break;
              }
            }

reader should be closed using finally block.