java 如何自动查找flink 最新的checkpoint
时间: 2024-01-28 12:04:27 浏览: 87
要自动查找 Flink 最新的 checkpoint,可以使用 Flink 的 REST API。具体地,可以使用以下步骤:
1. 首先,通过发送 HTTP GET 请求到 Flink 的 REST API `/jobs` 端点,获取 Flink 所有作业的列表。
2. 然后,遍历作业列表,找到你所关心的作业,并获取该作业的 JOB ID。
3. 接着,通过发送 HTTP GET 请求到 Flink 的 REST API `/jobs/:jobid/checkpoints` 端点,获取该作业所有 checkpoint 的列表。
4. 最后,遍历 checkpoint 列表,找到最新的 checkpoint。
Java 可以使用第三方 HTTP 客户端库(如 Apache HttpComponents,OkHttp 等)来发送 HTTP 请求,并使用 JSON 库(如 Jackson,Gson 等)来解析 REST API 返回的 JSON 数据。
阅读全文
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20241231044930.png)
![pdf](https://img-home.csdnimg.cn/images/20241231044930.png)
![zip](https://img-home.csdnimg.cn/images/20241231045053.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![-](https://img-home.csdnimg.cn/images/20241226111658.png)
![zip](https://img-home.csdnimg.cn/images/20241231045053.png)
![pdf](https://img-home.csdnimg.cn/images/20241231044930.png)
![zip](https://img-home.csdnimg.cn/images/20241231045053.png)
![zip](https://img-home.csdnimg.cn/images/20241231045053.png)
![pdf](https://img-home.csdnimg.cn/images/20241231044930.png)
![docx](https://img-home.csdnimg.cn/images/20241231044901.png)