From 1225b2b01dc8b5c4b4499c43ecdc5204bcf958d4 Mon Sep 17 00:00:00 2001
From: Neil <24886602+xiaows08@users.noreply.github.com>
Date: Tue, 1 Oct 2024 17:55:59 +0800
Subject: [PATCH] [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>
---
 .../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 8aeadb1fcc..b25bbdbe41 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 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;
     }
   }