SteNicholas commented on code in PR #250:
URL: https://github.com/apache/flink-table-store/pull/250#discussion_r932108840
##########
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileUtils.java:
##########
@@ -182,4 +180,20 @@ public static Stream<Long> listVersionedFiles(Path dir,
String prefix) throws IO
.filter(name -> name.startsWith(prefix))
.map(name -> Long.parseLong(name.substring(prefix.length())));
}
+
+ public static BulkFormat.Reader<RowData> createFormatReader(
+ BulkFormat<RowData, FileSourceSplit> format, Path file) throws
IOException {
+ if (!file.getFileSystem().exists(file)) {
+ throw new FileNotFoundException(
+ String.format(
+ "File '%s' not found, Possible causes: "
+ + "1.consumption is too slow, you can
improve the performance of consumption. "
+ + "2.snapshot expires too fast, you can
configure a larger snapshot.time-retained.",
Review Comment:
```suggestion
+ "2.For the situation that snapshot
expires too fast, you can configure 'snapshot.time-retained' option with a
larger value.",
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
