[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15611422#comment-15611422 ]
ASF GitHub Bot commented on FLINK-4800: --------------------------------------- Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2618 @mxm I just did. Let's wait for travis again. > Introduce the TimestampedFileInputSplit for Continuous File Processing > ---------------------------------------------------------------------- > > Key: FLINK-4800 > URL: https://issues.apache.org/jira/browse/FLINK-4800 > Project: Flink > Issue Type: Bug > Components: Streaming Connectors > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Priority: Minor > > Introduce the TimestampedFileInputSplit which extends the class > FileInputSplit and also contains: > i) the modification time of the file the split belongs to and also, and > ii) when checkpointing, the point the reader is currently reading from. > The latter will be useful for rescaling. With this addition, the > ContinuousFileMonitoringFunction sends TimestampedFileInputSplits > to the Readers, and the Readers' state now contain only > TimestampedFileInputSplits. -- This message was sent by Atlassian JIRA (v6.3.4#6332)