[ https://issues.apache.org/jira/browse/FLINK-3796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15251550#comment-15251550 ]
Aljoscha Krettek commented on FLINK-3796: ----------------------------------------- I think [~kkl0u] is currently working on the streaming file sources and I was under the impression that this would make the {{FileSourceFunction}} obsolete as well. > FileSourceFunction doesn't respect InputFormat's life cycle methods > -------------------------------------------------------------------- > > Key: FLINK-3796 > URL: https://issues.apache.org/jira/browse/FLINK-3796 > Project: Flink > Issue Type: Bug > Components: Streaming > Affects Versions: 1.0.0, 1.0.1, 1.0.2 > Reporter: Maximilian Michels > Assignee: Maximilian Michels > Fix For: 1.1.0 > > > 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). -- This message was sent by Atlassian JIRA (v6.3.4#6332)