[
https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4777:
--------------------------------------
Description: 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 file path filter afterwards.
Thus, this problem can't easily be avoided and needs to be taken care of by the
function itself. (was: 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.)
> 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.2.0, 1.1.2
> 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 file path filter afterwards. Thus, this problem can't easily
> be avoided and needs to be taken care of by the function itself.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
