[FLINK-3796] FileSourceFunction doesn't respect InputFormat's life cycle methods

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0, 1.0.1, 1.0.2
• Fix Version/s: 1.1.0
• Assignee: Maximilian Michels
• Reporter: Maximilian Michels
• Created: 20/Apr/16 17:10
• Updated: 28/Feb/19 11:14
• Resolved: 05/Aug/16 08:26

Description

The FileSourceFunction wraps InputFormat but doesn't execute its life cycle functions correctly.

1) It doesn't call close() before reading the next InputSplit via open(InputSplit split).

2) It calls close() even if no InputSplit has been read (and thus open(..) hasn't been called previously).

Issue Links

• is superceded by: FLINK-2314 Make Streaming File Sources Persistent