Maximilian Michels created FLINK-4777:
-----------------------------------------

             Summary: ContinuousFileMonitoringFunction may throw IOException 
when files are moved
                 Key: FLINK-4777
                 URL: https://issues.apache.org/jira/browse/FLINK-4777
             Project: Flink
          Issue Type: Bug
          Components: Streaming Connectors
    Affects Versions: 1.1.2, 1.2.0
            Reporter: Maximilian Michels
            Assignee: Maximilian Michels
            Priority: Critical
             Fix For: 1.2.0, 1.1.3


FileSystem.listStatus(path) may throw an IOException when it lists files and 
then retrieves their file status. This is quite common, e.g. editors which 
create temporary files and move them. The ContinuousFileMonitoringFunction can 
only apply a filter filter afterwards. Thus, this problem can't easily be 
avoided.



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

Reply via email to