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 9091cb3..9d61f32 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
@@ -4,8 +4,10 @@ import com.dtflys.forest.annotation.BaseRequest;
 import com.dtflys.forest.annotation.Get;
 import com.dtflys.forest.annotation.Query;
 import com.lanyuanxiaoyao.service.configuration.entity.PageResponse;
+import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiCleanerPlan;
 import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiCompactionPlan;
 import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiInstant;
+import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiRollbackPlan;
 import java.util.Map;
 import org.eclipse.collections.api.list.ImmutableList;
 
@@ -29,6 +31,18 @@ public interface HudiService {
     @Get("/timeline/read_compaction_plan_hdfs")
     HudiCompactionPlan readCompactionPlanHdfs(@Query("hdfs") String hdfs, @Query("instant") String instant);
 
+    @Get("/timeline/read_rollback_plan")
+    HudiRollbackPlan readRollbackPlan(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("instant") String instant);
+
+    @Get("/timeline/read_rollback_plan_hdfs")
+    HudiRollbackPlan readRollbackPlanHdfs(@Query("hdfs") String hdfs, @Query("instant") String instant);
+
+    @Get("/timeline/read_cleaner_plan")
+    HudiCleanerPlan readCleanerPlan(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("instant") String instant);
+
+    @Get("/timeline/read_cleaner_plan_hdfs")
+    HudiCleanerPlan readCleanerPlanHdfs(@Query("hdfs") String hdfs, @Query("instant") String instant);
+
     @Get("/timeline/list_pending_compaction")
     ImmutableList<HudiInstant> timelinePendingCompactionList(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
 }