[hudi] branch master updated: [HUDI-6395] Scheduling jobs should not fail when there is no scheduled compaction or clustering plan (#9009)

[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 587a53f8375 [HUDI-6395] Scheduling jobs should not fail when there is 
no scheduled compaction or clustering plan (#9009)
587a53f8375 is described below

commit 587a53f837523d775e1da515d58d4cdfe1d44de1
Author: ksmou <135721692+ks...@users.noreply.github.com>
AuthorDate: Tue Jun 20 16:27:39 2023 +0800

    [HUDI-6395] Scheduling jobs should not fail when there is no scheduled 
compaction or clustering plan (#9009)
---
 .../src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java  | 4 ++--
 .../src/main/java/org/apache/hudi/utilities/HoodieCompactor.java      | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java
 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java
index 3e636855c96..f17af1b2b55 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java
@@ -29,7 +29,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.HoodieClusteringException;
 import org.apache.hudi.table.HoodieSparkTable;
 
 import com.beust.jcommander.JCommander;
@@ -216,7 +215,8 @@ public class HoodieClusteringJob {
           LOG.info("Found the earliest scheduled clustering instant which will 
be executed: "
               + cfg.clusteringInstantTime);
         } else {
-          throw new HoodieClusteringException("There is no scheduled 
clustering in the table.");
+          LOG.info("There is no scheduled clustering in the table.");
+          return 0;
         }
       }
       Option<HoodieCommitMetadata> commitMetadata = 
client.cluster(cfg.clusteringInstantTime).getCommitMetadata();
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 7f463b32319..c1958e76e6b 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.HoodieCompactionException;
 import org.apache.hudi.exception.HoodieException;
 import org.apache.hudi.table.action.HoodieWriteMetadata;
 import 
org.apache.hudi.table.action.compact.strategy.LogFileSizeBasedCompactionStrategy;
@@ -268,7 +267,8 @@ public class HoodieCompactor {
           LOG.info("Found the earliest scheduled compaction instant which will 
be executed: "
               + cfg.compactionInstantTime);
         } else {
-          throw new HoodieCompactionException("There is no scheduled 
compaction in the table.");
+          LOG.info("There is no scheduled compaction in the table.");
+          return 0;
         }
       }
       HoodieWriteMetadata<JavaRDD<WriteStatus>> compactionMetadata = 
client.compact(cfg.compactionInstantTime);