You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Guowei Ma (Jira)" <ji...@apache.org> on 2022/04/27 07:35:00 UTC
[jira] [Comment Edited] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors
[ 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)