[hudi] branch master updated: [HUDI-6670] Fix timeline check in metadata table validator (#9405)

[yihua]

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 638e52d90ed [HUDI-6670] Fix timeline check in metadata table validator 
(#9405)
638e52d90ed is described below

commit 638e52d90eda2d7c1e78a87f08427e5e3bf0a46c
Author: Y Ethan Guo <ethan.guoyi...@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.");