[Improve] flink app cancel bug fixed. (#4013)

apache · Aug 31, 2024 · 4441df3 · 4441df3
1 parent bfdb289
commit 4441df3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/...-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java b/...-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
@@ -323,6 +323,7 @@ public static Integer shouldTracking(@Nonnull FlinkAppState state) {
       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
@@ -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]: {