[FLINK-3197] InputStream not closed in BinaryInputFormat#createStatistics

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 31/Dec/15 20:08
• Updated: 15/Jan/16 10:54
• Resolved: 15/Jan/16 10:54

Description

Here is related code:

      FSDataInputStream fdis = file.getPath().getFileSystem().open(file.getPath(), blockInfo.getInfoSize());
      fdis.seek(file.getLen() - blockInfo.getInfoSize());

      blockInfo.read(new DataInputViewStreamWrapper(fdis));
      totalCount += blockInfo.getAccumulatedRecordCount();

fdis / wrapper should be closed upon leaving the method