(incubator-streampark) branch dev updated: [Bug]Fix jar of flink app with task dependencies can be successfully deleted (#4126)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 2b60a65f5 [Bug]Fix jar of flink app with task dependencies can be 
successfully deleted (#4126)
2b60a65f5 is described below

commit 2b60a65f5278d7a894d6b311edabb75ab56a795c
Author: Happy-shi <1900022...@pku.edu.cn>
AuthorDate: Sat Nov 2 18:34:14 2024 +0800

    [Bug]Fix jar of flink app with task dependencies can be successfully 
deleted (#4126)
---
 .../streampark/console/core/service/impl/ResourceServiceImpl.java  | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
index 9a2bf32b8..4ca4d3514 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
@@ -493,6 +493,13 @@ public class ResourceServiceImpl extends 
ServiceImpl<ResourceMapper, Resource>
             .collect(Collectors.toMap(FlinkApplication::getId, application -> 
application));
 
         // Get the application that depends on this resource
+        for (FlinkApplication app : applications) {
+            if (resource.getResourceName().equals(app.getJar())
+                && !dependApplications.contains(app)) {
+                dependApplications.add(app);
+            }
+        }
+
         List<FlinkSql> flinkSqls = 
flinkSqlService.listByTeamId(resource.getTeamId());
         for (FlinkSql flinkSql : flinkSqls) {
             String sqlTeamResource = flinkSql.getTeamResource();