This is an automated email from the ASF dual-hosted git repository. forwardxu pushed a commit to branch release-0.12.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 4fe2aec44acefc7ec857836b54af69dce5f41bda Author: XuQianJin-Stars <forwar...@apache.com> AuthorDate: Tue Dec 13 14:52:03 2022 +0800 fix read log not exist --- .../org/apache/hudi/common/table/log/HoodieLogFormatReader.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java index c48107e392..7f67c76870 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java @@ -67,8 +67,12 @@ public class HoodieLogFormatReader implements HoodieLogFormat.Reader { this.internalSchema = internalSchema == null ? InternalSchema.getEmptyInternalSchema() : internalSchema; if (logFiles.size() > 0) { HoodieLogFile nextLogFile = logFiles.remove(0); - this.currentReader = new HoodieLogFileReader(fs, nextLogFile, readerSchema, bufferSize, readBlocksLazily, false, - enableRecordLookups, recordKeyField, internalSchema); + if (fs.exists(nextLogFile.getPath())) { + this.currentReader = new HoodieLogFileReader(fs, nextLogFile, readerSchema, bufferSize, readBlocksLazily, false, + enableRecordLookups, recordKeyField, internalSchema); + } else { + LOG.warn("File does not exist: " + nextLogFile.getPath()); + } } }