Stephan Ewen created FLINK-2314:
-----------------------------------

             Summary: Make Streaming File Sources Persistent
                 Key: FLINK-2314
                 URL: https://issues.apache.org/jira/browse/FLINK-2314
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
    Affects Versions: 0.9
            Reporter: Stephan Ewen


Streaming File sources should participate in the checkpointing. They should 
track the bytes they read from the file and checkpoint it.

One can look at the sequence generating source function for an example of a 
checkpointed source.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to