(incubator-streampark) branch release-2.1.4 updated: [Bug] fix CheckPoint Failure Options dose not take effect (#4104)

[benjobs]

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

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


The following commit(s) were added to refs/heads/release-2.1.4 by this push:
     new 1225b2b01 [Bug] fix CheckPoint Failure Options dose not take effect 
(#4104)
1225b2b01 is described below

commit 1225b2b01dc8b5c4b4499c43ecdc5204bcf958d4
Author: Neil <24886602+xiaow...@users.noreply.github.com>
AuthorDate: Tue Oct 1 17:55:59 2024 +0800

    [Bug] fix CheckPoint Failure Options dose not take effect (#4104)
    
    * fix(#4085): CheckPoint Failure Options dose not take effect
    
    ---------
    
    Co-authored-by: benjobs <benj...@apache.org>
---
 .../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;
     }
   }