(incubator-streampark) branch dev-2.1.5 updated: [Improve] flink lost state improvement

[be...@apache.org]

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 20e6bfc5b [Improve] flink lost state improvement
20e6bfc5b is described below

commit 20e6bfc5b79f19f57196219356eedb147937c0c8
Author: benjobs <be...@apache.org>
AuthorDate: Wed Jul 24 17:33:57 2024 +0800

    [Improve] flink lost state improvement
---
 .../org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
index 36e115b8f..1fbef57e9 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
@@ -252,6 +252,7 @@ public class FlinkAppHttpWatcher {
           } else if (DateUtils.toSecondDuration(lostTime, new Date()) >= 30) {
             savePointService.expire(application.getId());
             application.setState(FlinkAppState.LOST.getValue());
+            WATCHING_APPS.remove(application.getId());
             LOST_CACHE.invalidate(application.getId());
           }
         } else {