(streampark) branch dev updated: [hotfix][console-service] Fixed finished job is no need alert. (#4293)

[panyuepeng]

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

panyuepeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new fecba858c [hotfix][console-service] Fixed finished job is no need 
alert. (#4293)
fecba858c is described below

commit fecba858c1c7b4180db3f5590e55c428dafc8a5a
Author: ouyangwulin <mr.art...@gmail.com>
AuthorDate: Fri Jan 23 16:22:14 2026 +0800

    [hotfix][console-service] Fixed finished job is no need alert. (#4293)
---
 .../console/core/watcher/FlinkAppHttpWatcher.java     | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
old mode 100644
new mode 100755
index 3e57dce29..aeec8cd8b
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
@@ -485,7 +485,6 @@ public class FlinkAppHttpWatcher {
                 doPersistMetrics(application, false);
                 break;
             case CANCELED:
-            case FINISHED:
                 log.info(
                     "[StreamPark][FlinkAppHttpWatcher] getFromFlinkRestApi, 
job state {}, stop tracking and delete stopFrom!",
                     currentState.name());
@@ -504,6 +503,24 @@ public class FlinkAppHttpWatcher {
                 doPersistMetrics(application, true);
                 cleanOptioning(optionState, application.getId());
                 break;
+            case FINISHED:
+                log.info(
+                    "[StreamPark][FlinkAppHttpWatcher] getFromFlinkRestApi, 
job state {}, stop tracking and delete stopFrom!",
+                    currentState.name());
+                cleanSavepoint(application);
+                application.setState(currentState.getValue());
+                if (StopFromEnum.NONE.equals(stopFrom) || 
applicationInfoService.checkAlter(application)) {
+                    if (StopFromEnum.NONE.equals(stopFrom)) {
+                        log.info(
+                            "[StreamPark][FlinkAppHttpWatcher] 
getFromFlinkRestApi, job finished is not form StreamPark,savepoint expired!");
+                        savepointService.expire(application.getId());
+                    }
+                    stopCanceledJob(application.getId());
+                }
+                STOP_FROM_MAP.remove(application.getId());
+                doPersistMetrics(application, true);
+                cleanOptioning(optionState, application.getId());
+                break;
             case FAILED:
                 cleanSavepoint(application);
                 STOP_FROM_MAP.remove(application.getId());