[Bug]Fix jar of flink app with task dependencies can be successfully …

…deleted (#4126)
apache · Nov 2, 2024 · 2b60a65 · 2b60a65
1 parent 3a44fe0
commit 2b60a65
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...ce/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java b/...ce/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
@@ -493,6 +493,13 @@ private List<FlinkApplication> getResourceApplicationsById(Resource 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();