[hudi] branch master updated: [HUDI-6458] Scheduling jobs should not fail when there is no completed commits (#9097)

[danny0405]

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 a94db121b3a [HUDI-6458] Scheduling jobs should not fail when there is 
no completed commits (#9097)
a94db121b3a is described below

commit a94db121b3aa05fd2243cb0a7794a2c20048065b
Author: ksmou <135721692+ks...@users.noreply.github.com>
AuthorDate: Fri Jun 30 19:37:33 2023 +0800

    [HUDI-6458] Scheduling jobs should not fail when there is no completed 
commits (#9097)
---
 .../src/main/java/org/apache/hudi/utilities/HoodieCompactor.java      | 4 ----
 .../src/main/java/org/apache/hudi/utilities/UtilHelpers.java          | 3 ---
 2 files changed, 7 deletions(-)

diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java
index c1958e76e6b..603502affb6 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java
@@ -30,7 +30,6 @@ import org.apache.hudi.common.table.timeline.HoodieTimeline;
 import org.apache.hudi.common.util.Option;
 import org.apache.hudi.common.util.StringUtils;
 import org.apache.hudi.config.HoodieCleanConfig;
-import org.apache.hudi.exception.HoodieException;
 import org.apache.hudi.table.action.HoodieWriteMetadata;
 import 
org.apache.hudi.table.action.compact.strategy.LogFileSizeBasedCompactionStrategy;
 
@@ -293,9 +292,6 @@ public class HoodieCompactor {
 
   private String getSchemaFromLatestInstant() throws Exception {
     TableSchemaResolver schemaUtil = new TableSchemaResolver(metaClient);
-    if 
(metaClient.getActiveTimeline().getCommitsTimeline().filterCompletedInstants().countInstants()
 == 0) {
-      throw new HoodieException("Cannot run compaction without any completed 
commits");
-    }
     Schema schema = schemaUtil.getTableAvroSchema(false);
     return schema.toString();
   }
diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java
index 5c09cf71a2b..a0d241752c5 100644
--- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java
+++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java
@@ -589,9 +589,6 @@ public class UtilHelpers {
 
   public static String getSchemaFromLatestInstant(HoodieTableMetaClient 
metaClient) throws Exception {
     TableSchemaResolver schemaResolver = new TableSchemaResolver(metaClient);
-    if 
(metaClient.getActiveTimeline().getCommitsTimeline().filterCompletedInstants().countInstants()
 == 0) {
-      throw new HoodieException("Cannot run clustering without any completed 
commits");
-    }
     Schema schema = schemaResolver.getTableAvroSchema(false);
     return schema.toString();
   }