You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yi...@apache.org on 2025/10/02 03:40:44 UTC

(hudi) branch master updated: chore: Fix logging when file is not found (#14032)

This is an automated email from the ASF dual-hosted git repository.

yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new a65c636cff4b chore: Fix logging when file is not found (#14032)
a65c636cff4b is described below

commit a65c636cff4b21b470772636f889d9241b388a91
Author: Tim Brown <ti...@onehouse.ai>
AuthorDate: Wed Oct 1 23:40:38 2025 -0400

    chore: Fix logging when file is not found (#14032)
---
 hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java b/hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java
index 30397e79d458..e38f8048eca6 100644
--- a/hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java
+++ b/hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java
@@ -32,6 +32,7 @@ import java.io.BufferedReader;
 import java.io.ByteArrayOutputStream;
 import java.io.Closeable;
 import java.io.File;
+import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
@@ -236,6 +237,9 @@ public class FileIOUtils {
   public static Option<byte[]> readDataFromPath(HoodieStorage storage, StoragePath detailPath, boolean ignoreIOE) {
     try (InputStream is = storage.open(detailPath)) {
       return Option.of(FileIOUtils.readAsByteArray(is));
+    } catch (FileNotFoundException fnfe) {
+      LOG.debug("No file found at path {}", detailPath);
+      return Option.empty();
     } catch (IOException e) {
       LOG.warn("Could not read commit details from {}", detailPath, e);
       if (!ignoreIOE) {