[
https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528692#comment-17528692
]
Guowei Ma commented on FLINK-27424:
-----------------------------------
Thanks for your information.
But are you sure that the file is processed already? For example is there any
log about this?
BTW the source would filter the processed file by the modified time of the
file. Is that possible the file's modified time is changed by some reason.
> StreamExecutionEnvironment.readFile() api monitor file directory errors
> ------------------------------------------------------------------------
>
> Key: FLINK-27424
> URL: https://issues.apache.org/jira/browse/FLINK-27424
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.14.3
> Reporter: zhangqw152
> Priority: Major
> Attachments: image-2022-04-27-14-27-33-320.png
>
>
> I use StreamExecutionEnvironment.readFile() api to monitor file
> directory,when a file in the directory is deleted, the program will report an
> error(FileNofoundException)
> !image-2022-04-27-14-27-33-320.png!
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
