[
https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528604#comment-17528604
]
Guowei Ma edited comment on FLINK-27424 at 4/27/22 7:34 AM:
------------------------------------------------------------
Hi, [~zhangqw152]
IMHO I do not think this is a bug. The source finds the `io_wcdma_mobile_xxxx`
file is deleted when it begins to create the split of the
`io_wcdma_mobile_xxxx` file. So the source want to tell `Hey! there is
something wrong and somebody need to take a look!`
Or would you like to enlighten me a little about what the behavior you expect?
Thanks
was (Author: maguowei):
Hi, [~zhangqw152]
IMHO I do not think this is a bug. The source finds the `io_wcdma_mobile_xxxx`
file is deleted for reason when it begins to create the split of the
`io_wcdma_mobile_xxxx` file. So the source want to tell `Hey! there is
something wrong and somebody need to take a look!`
Or would you like to enlighten me a little about what the behavior you expect?
Thanks
> 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)
