[
https://issues.apache.org/jira/browse/FLINK-28715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28715:
---------------------------------
Description:
When reading a file, if it is found that the file does not exist, it directly
throws a file not found exception, which is often difficult for users to
understand.
We can make it more clear in the exception message, e.g.
The file cannot be found, this may be because the read is too slow and the
previous snapshot expired, you can configure a larger snapshot.time-retained or
speed up your read.
Caused by: java.io.FileNotFoundException: File does not exist:
at
org.apache.flink.table.store.file.utils.FileUtils.getFileSize(FileUtils.java:94)
~[flink-table-store-dist-0.2.jar:0.2-SNAPSHOT]
at
org.apache.flink.table.store.file.data.DataFileReader$DataFileRecordReader.<init>(DataFileReader.java:86)
~[flink-table-store-dist-0.2.jar:0.2-SNAPSHOT]
was:
When reading a file, if it is found that the file does not exist, it directly
throws a file not found exception, which is often difficult for users to
understand.
We can make it more clear in the exception message, e.g.
The file cannot be found, this may be because the read is too slow and the
previous snapshot expired, you can configure a larger snapshot.time-retained or
speed up your read.
> Throw better exception when file not found in reading
> -----------------------------------------------------
>
> Key: FLINK-28715
> URL: https://issues.apache.org/jira/browse/FLINK-28715
> Project: Flink
> Issue Type: Improvement
> Components: Table Store
> Reporter: Jingsong Lee
> Priority: Blocker
> Fix For: table-store-0.2.0
>
>
> When reading a file, if it is found that the file does not exist, it directly
> throws a file not found exception, which is often difficult for users to
> understand.
> We can make it more clear in the exception message, e.g.
> The file cannot be found, this may be because the read is too slow and the
> previous snapshot expired, you can configure a larger snapshot.time-retained
> or speed up your read.
> Caused by: java.io.FileNotFoundException: File does not exist:
> at
> org.apache.flink.table.store.file.utils.FileUtils.getFileSize(FileUtils.java:94)
> ~[flink-table-store-dist-0.2.jar:0.2-SNAPSHOT]
> at
> org.apache.flink.table.store.file.data.DataFileReader$DataFileRecordReader.<init>(DataFileReader.java:86)
> ~[flink-table-store-dist-0.2.jar:0.2-SNAPSHOT]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
