[ 
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)

Reply via email to