lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(flink-query): 修复 checkpoint id 的类型为 Long

Browse Source
This commit is contained in:
兰缘小妖
2023-05-05 23:05:22 +08:00
parent eabe69a30d
commit 1dde155fac
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/controller/FlinkController.java
View File

@@ -63,7 +63,7 @@ public class FlinkController {
} }
@GetMapping("/checkpoint") @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); return flinkService.checkpoint(url, vertexId, checkpointId);
} }

2
service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/FlinkService.java
View File

@@ -25,7 +25,7 @@ public interface FlinkService {
FlinkCheckpointOverview checkpointOverview(String url, String vertexId) throws JsonProcessingException; 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; FlinkCheckpointConfig checkpointConfig(String url, String vertexId) throws JsonProcessingException;

2
service-flink-query/src/main/java/com/lanyuanxiaoyao/service/flink/service/impl/FlinkServiceImpl.java
View File

@@ -98,7 +98,7 @@ public class FlinkServiceImpl implements FlinkService {
@Cacheable(value = "flink-checkpoint", sync = true) @Cacheable(value = "flink-checkpoint", sync = true)
@Retryable(Throwable.class) @Retryable(Throwable.class)
@Override @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); return mapper.readValue(get(url, StrUtil.format("/v1/jobs/{}/checkpoints/details/{}", vertexId, checkpointId)), FlinkCheckpoint.class);
} }

2
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/FlinkService.java
View File

@@ -37,7 +37,7 @@ public interface FlinkService {
FlinkCheckpointOverview checkpointOverview(@Query("url") String url, @Query("vertex_id") String vertexId); FlinkCheckpointOverview checkpointOverview(@Query("url") String url, @Query("vertex_id") String vertexId);
@Get("/flink/checkpoint") @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") @Get("/flink/checkpoint_config")
FlinkCheckpointConfig checkpointConfig(@Query("url") String url, @Query("vertex_id") String vertexId); FlinkCheckpointConfig checkpointConfig(@Query("url") String url, @Query("vertex_id") String vertexId);