[hudi] 41/45: fix read log not exist

[forwardxu]

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());
+      }
     }
   }