[
https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528704#comment-17528704
]
Guowei Ma commented on FLINK-27424:
-----------------------------------
Would you like to enable the debug log and share more information?
I want to see why the file does not filter by the modification time.
{code:java}
LOG.debug(
"Ignoring "
+ filePath
+ ", with mod time= "
+ modificationTime
+ " and global mod time= "
+ globalModificationTime); {code}
> 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)
