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
index 3e57dce297..6bfba478b5 100644
--- 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
@@ -498,7 +498,7 @@ private void handleNotRunState(
                         savepointService.expire(application.getId());
                     }
                     stopCanceledJob(application.getId());
-                    doAlert(application, FlinkAppStateEnum.CANCELED);
+                    doAlert(application, currentState);
                 }
                 STOP_FROM_MAP.remove(application.getId());
                 doPersistMetrics(application, true);
@@ -509,7 +509,7 @@ private void handleNotRunState(
                 STOP_FROM_MAP.remove(application.getId());
                 application.setState(FlinkAppStateEnum.FAILED.getValue());
                 doPersistMetrics(application, true);
-                doAlert(application, FlinkAppStateEnum.FAILED);
+                doAlert(application, currentState);
                 applicationActionService.start(application, true);
                 break;
             case RESTARTING: