[FLINK-4024] FileSourceFunction not adjusted to new IF lifecycle

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 1.1.0
• Assignee: Kostas Kloudas
• Reporter: Chesnay Schepler
• Created: 05/Jun/16 17:36
• Updated: 28/Feb/19 11:14
• Resolved: 16/Jun/16 07:44

Description

The InputFormat lifecycle was extended in ac2137cfa5e63bd4f53a4b7669dc591ab210093f, adding additional open-/closeInputFormat() methods.

The streaming FileSourceFunction was not adjusted for this change, and thus will fail for every InputFormat that leverages these new methods.

Issue Links

• links to: GitHub Pull Request #2100