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) {