You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by pw...@apache.org on 2023/08/18 08:59:23 UTC
[hudi] 09/29: [HUDI-6670] Fix timeline check in metadata table validator (#9405)
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 <et...@gmail.com>
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.");