SteNicholas commented on code in PR #250:
URL: https://github.com/apache/flink-table-store/pull/250#discussion_r932107942
##########
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. "
Review Comment:
For the users, "you can improve the performance of consumption." is hard to
do something for improvement, which is better to tell users how to improve.
--
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]
