[Improve] get latest checkpoint bug fixed.

apache · Oct 1, 2024 · 9d5263d · 9d5263d
1 parent d88be6e
commit 9d5263d
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/...e-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java b/...e-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
@@ -96,8 +96,10 @@ public String getPath() {
   @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 List<CheckPoint> getLatestCheckpoint() {
       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;
     }
   }