diff --git a/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/controller/FlinkController.java b/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/controller/FlinkController.java
index 143feec..c02b1cb 100644
--- a/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/controller/FlinkController.java
+++ b/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/controller/FlinkController.java
@@ -63,7 +63,7 @@ public class FlinkController {
     }
 
     @GetMapping("/checkpoint")
-    public FlinkCheckpoint checkpoint(@RequestParam("url") String url, @RequestParam("vertex_id") String vertexId, @RequestParam("checkpoint_id") String checkpointId) throws JsonProcessingException {
+    public FlinkCheckpoint checkpoint(@RequestParam("url") String url, @RequestParam("vertex_id") String vertexId, @RequestParam("checkpoint_id") Long checkpointId) throws JsonProcessingException {
         return flinkService.checkpoint(url, vertexId, checkpointId);
     }
 
diff --git a/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/FlinkService.java b/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/FlinkService.java
index 88dfedf..e9c0fb0 100644
--- a/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/FlinkService.java
+++ b/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/FlinkService.java
@@ -25,7 +25,7 @@ public interface FlinkService {
 
     FlinkCheckpointOverview checkpointOverview(String url, String vertexId) throws JsonProcessingException;
 
-    FlinkCheckpoint checkpoint(String url, String vertexId, String checkpointId) throws JsonProcessingException;
+    FlinkCheckpoint checkpoint(String url, String vertexId, Long checkpointId) throws JsonProcessingException;
 
     FlinkCheckpointConfig checkpointConfig(String url, String vertexId) throws JsonProcessingException;
 
diff --git a/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/impl/FlinkServiceImpl.java b/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/impl/FlinkServiceImpl.java
index 9273e1c..88f51c4 100644
--- a/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/impl/FlinkServiceImpl.java
+++ b/service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/impl/FlinkServiceImpl.java
@@ -98,7 +98,7 @@ public class FlinkServiceImpl implements FlinkService {
     @Cacheable(value = "flink-checkpoint", sync = true)
     @Retryable(Throwable.class)
     @Override
-    public FlinkCheckpoint checkpoint(String url, String vertexId, String checkpointId) throws JsonProcessingException {
+    public FlinkCheckpoint checkpoint(String url, String vertexId, Long checkpointId) throws JsonProcessingException {
         return mapper.readValue(get(url, StrUtil.format("/v1/jobs/{}/checkpoints/details/{}", vertexId, checkpointId)), FlinkCheckpoint.class);
     }
 
diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/FlinkService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/FlinkService.java
index 4c1ea91..77afd4d 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/FlinkService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/FlinkService.java
@@ -37,7 +37,7 @@ public interface FlinkService {
     FlinkCheckpointOverview checkpointOverview(@Query("url") String url, @Query("vertex_id") String vertexId);
 
     @Get("/flink/checkpoint")
-    FlinkCheckpoint checkpoint(@Query("url") String url, @Query("vertex_id") String vertexId, @Query("checkpoint_id") String checkpointId);
+    FlinkCheckpoint checkpoint(@Query("url") String url, @Query("vertex_id") String vertexId, @Query("checkpoint_id") Long checkpointId);
 
     @Get("/flink/checkpoint_config")
     FlinkCheckpointConfig checkpointConfig(@Query("url") String url, @Query("vertex_id") String vertexId);