You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by fo...@apache.org on 2023/01/04 03:32:51 UTC
[hudi] 41/45: fix read log not exist
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 <fo...@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());
+ }
}
}