[
https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528698#comment-17528698
]
zhangqw152 commented on FLINK-27424:
------------------------------------
I am testing that the file has been processed, and deleting the file will cause
the program to report an error
> 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)