(incubator-streampark) branch dev-2.1.5 updated: [Improve] get latest checkpoint bug fixed.

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.5
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
     new 9d5263d4a [Improve] get latest checkpoint bug fixed.
9d5263d4a is described below

commit 9d5263d4a83dc1adeed1efbfb090053da45e8864
Author: benjobs <benj...@apache.org>
AuthorDate: Tue Oct 1 17:36:03 2024 +0800

    [Improve] get latest checkpoint bug fixed.
---
 .../streampark/console/core/metrics/flink/CheckPoints.java    | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
index 8aeadb1fc..b25bbdbe4 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
@@ -96,8 +96,10 @@ public class CheckPoints implements Serializable {
   @Getter
   @Setter
   public static class Latest implements Serializable {
+
     private CheckPoint completed;
     private CheckPoint savepoint;
+    private CheckPoint failed;
 
     @JsonIgnore
     public List<CheckPoint> getLatestCheckpoint() {
@@ -108,6 +110,15 @@ public class CheckPoints implements Serializable {
       if (savepoint != null) {
         checkPoints.add(savepoint);
       }
+      if (failed != null) {
+        if (completed == null) {
+          checkPoints.add(failed);
+        } else {
+          if (failed.getId() > completed.getId()) {
+            checkPoints.add(failed);
+          }
+        }
+      }
       return checkPoints;
     }
   }