This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit d70c15f40414e6b517101573ff70baeff6cf1d81 Author: Y Ethan Guo <[email protected]> AuthorDate: Thu Aug 10 20:29:36 2023 -0700 [HUDI-6670] Fix timeline check in metadata table validator (#9405) --- .../org/apache/hudi/utilities/HoodieMetadataTableValidator.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java index d79957c735f..29e59df6935 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java @@ -491,10 +491,10 @@ public class HoodieMetadataTableValidator implements Serializable { .setConf(jsc.hadoopConfiguration()).setBasePath(new Path(cfg.basePath, HoodieTableMetaClient.METADATA_TABLE_FOLDER_PATH).toString()) .setLoadActiveTimelineOnLoad(true) .build(); - int finishedInstants = mdtMetaClient.getActiveTimeline().filterCompletedInstants().countInstants(); + int finishedInstants = mdtMetaClient.getCommitsTimeline().filterCompletedInstants().countInstants(); if (finishedInstants == 0) { - if (metaClient.getActiveTimeline().filterCompletedInstants().countInstants() == 0) { - LOG.info("There is no completed instant both in metadata table and corresponding data table."); + if (metaClient.getCommitsTimeline().filterCompletedInstants().countInstants() == 0) { + LOG.info("There is no completed commit in both metadata table and corresponding data table."); return false; } else { throw new HoodieValidationException("There is no completed instant for metadata table.");
