(incubator-streampark) branch dev-2.1.4 updated: resolving streampark flink on k8s that flink task status is failed but pod still running. (#3634)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.4 by this push:
     new 01bece73d resolving streampark flink on k8s that flink task status is 
failed but pod still running. (#3634)
01bece73d is described below

commit 01bece73dce30c54427894e8091b6c5c25503a81
Author: Dimitri <108189530+dimitri...@users.noreply.github.com>
AuthorDate: Wed Mar 27 15:23:38 2024 +0800

    resolving streampark flink on k8s that flink task status is failed but pod 
still running. (#3634)
---
 .../streampark/console/core/task/FlinkK8sChangeEventListener.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkK8sChangeEventListener.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkK8sChangeEventListener.java
index b0f3f5f14..20bea91da 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkK8sChangeEventListener.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkK8sChangeEventListener.java
@@ -71,9 +71,12 @@ public class FlinkK8sChangeEventListener {
     TrackId trackId = event.trackId();
     // get pre application record
     Application app = applicationService.getById(trackId.appId());
-    if (app == null || FlinkAppState.isEndState(app.getState())) {
+    if (app == null) {
       return;
     }
+    if (FlinkAppState.isEndState(app.getState())) {
+      log.info("job [{}] is EndState, but also update it.", app.getJobName());
+    }
 
     // update application record
     setByJobStatusCV(app, jobStatus);