From 1dde155fac3b9427122c9969451f4e308dd4c99d Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Fri, 5 May 2023 23:05:22 +0800 Subject: [PATCH] =?UTF-8?q?fix(flink-query):=20=E4=BF=AE=E5=A4=8D=20checkp?= =?UTF-8?q?oint=20id=20=E7=9A=84=E7=B1=BB=E5=9E=8B=E4=B8=BA=20Long?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/flink/controller/FlinkController.java | 2 +- .../com/lanyuanxiaoyao/service/flink/service/FlinkService.java | 2 +- .../service/flink/service/impl/FlinkServiceImpl.java | 2 +- .../com/lanyuanxiaoyao/service/forest/service/FlinkService.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) 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);