This is an automated email from the ASF dual-hosted git repository.
danny0405 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 60b190975c8 [MINOR] Log details when the metadata files are not found
(#12279)
60b190975c8 is described below
commit 60b190975c83a88f1d269fa9537aa5fcfb5d7e04
Author: zhuanshenbsj1 <[email protected]>
AuthorDate: Thu Dec 12 15:30:29 2024 +0800
[MINOR] Log details when the metadata files are not found (#12279)
---
.../hudi/common/table/timeline/versioning/v2/ActiveTimelineV2.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/v2/ActiveTimelineV2.java
b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/v2/ActiveTimelineV2.java
index e44c30dc27f..497ed0f0eca 100644
---
a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/v2/ActiveTimelineV2.java
+++
b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/v2/ActiveTimelineV2.java
@@ -506,8 +506,6 @@ public class ActiveTimelineV2 extends BaseTimelineV2
implements HoodieActiveTime
HoodieInstant toInstant,
Option<byte[]> data) {
ValidationUtils.checkArgument(fromInstant.requestedTime().equals(toInstant.requestedTime()),
String.format("%s and %s are not consistent when transition state.",
fromInstant, toInstant));
String fromInstantFileName =
instantFileNameGenerator.getFileName(fromInstant);
- // Ensures old state exists in timeline
- LOG.info("Checking for file exists ?" +
getInstantFileNamePath(fromInstantFileName));
try {
if (metaClient.getTimelineLayoutVersion().isNullVersion()) {
// Re-create the .inflight file by opening a new file and write the
commit metadata in
@@ -524,8 +522,10 @@ public class ActiveTimelineV2 extends BaseTimelineV2
implements HoodieActiveTime
"Could not rename " + fromInstantPath + " to " + toInstantPath);
}
} else {
+ // Ensures old state exists in timeline
ValidationUtils.checkArgument(
-
metaClient.getStorage().exists(getInstantFileNamePath(fromInstantFileName)));
+
metaClient.getStorage().exists(getInstantFileNamePath(fromInstantFileName)),
+ "File " + getInstantFileNamePath(fromInstantFileName) + " does not
exist!");
createCompleteFileInMetaPath(shouldLock, toInstant, data);
}
} catch (IOException e) {
