[Bug] fix CheckPoint Failure Options dose not take effect (#4104)

* fix(#4085): CheckPoint Failure Options dose not take effect --------- Co-authored-by: benjobs <benjobs@apache.org>
apache · Oct 1, 2024 · 1225b2b · 1225b2b
1 parent fd116a1
commit 1225b2b
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;
     }
   }