(incubator-streampark) branch dev-2.1.5 updated: [Improve] flink app cancel bug fixed. (#4013)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
     new 4441df31e [Improve] flink app cancel bug fixed. (#4013)
4441df31e is described below

commit 4441df31ee940ab0dec726d4b592c1c93d90ee7d
Author: benjobs <benj...@apache.org>
AuthorDate: Sat Aug 31 23:30:46 2024 +0800

    [Improve] flink app cancel bug fixed. (#4013)
---
 .../main/java/org/apache/streampark/console/core/entity/Application.java | 1 +
 .../streampark-console-webapp/src/views/flink/app/components/State.tsx   | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
index 79c168e7b..b02f668c3 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
@@ -323,6 +323,7 @@ public class Application implements Serializable {
       case FINISHED:
       case FAILED:
       case CANCELED:
+      case KILLED:
       case TERMINATED:
       case POS_TERMINATED:
       case LOST:
diff --git 
a/streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx
 
b/streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx
index 8aae8b47e..fc44487de 100644
--- 
a/streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx
+++ 
b/streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx
@@ -54,6 +54,7 @@ export const stateMap = {
   [AppStateEnum.FAILED]: { color: '#f5222d', title: 
t('flink.app.runState.failed') },
   [AppStateEnum.CANCELLING]: { color: '#faad14', title: 
t('flink.app.runState.cancelling') },
   [AppStateEnum.CANCELED]: { color: '#fa8c16', title: 
t('flink.app.runState.canceled') },
+  [AppStateEnum.KILLED]: { color: '#fa8c16', title: 
t('flink.app.runState.canceled') },
   [AppStateEnum.FINISHED]: { color: '#1890ff', title: 
t('flink.app.runState.finished') },
   [AppStateEnum.SUSPENDED]: { color: '#722ed1', title: 
t('flink.app.runState.suspended') },
   [AppStateEnum.RECONCILING]: {