diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java
index a631f7c..1a0d8ec 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java
@@ -47,6 +47,9 @@ public interface HudiService {
     @Get("/timeline/list_pending_compaction")
     ImmutableList<HudiInstant> timelinePendingCompactionList(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
 
+    @Get("/timeline/exists_compaction_plan")
+    Boolean existsCompactionPlan(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
+
     @Get("/table/schema")
     ImmutableMap<String, Object> schema(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
 
diff --git a/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java b/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java
index ab82891..a8f2c8a 100644
--- a/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java
+++ b/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java
@@ -140,4 +140,12 @@ public class TimelineController {
     ) throws IOException {
         return timelineService.pendingCompactionTimeline(flinkJobId, alias);
     }
+
+    @GetMapping("exists_compaction_plan")
+    public Boolean existsCompactionPlan(
+            @RequestParam("flink_job_id") Long flinkJobId,
+            @RequestParam("alias") String alias
+    ) throws IOException {
+        return !timelineService.pendingCompactionTimeline(flinkJobId, alias).isEmpty();
+    }
 }