[Bug]Fix jar library with task dependencies can be successfully delet…

…ed (#4124) Co-authored-by: Zhiwei Shi <[email protected]>
apache · Nov 1, 2024 · 3a44fe0 · 3a44fe0
1 parent ef78fdd
commit 3a44fe0
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -497,7 +497,7 @@ private List<FlinkApplication> getResourceApplicationsById(Resource resource) {
         for (FlinkSql flinkSql : flinkSqls) {
             String sqlTeamResource = flinkSql.getTeamResource();
             if (sqlTeamResource != null
-                && sqlTeamResource.contains(String.valueOf(resource.getTeamId()))) {
+                && sqlTeamResource.contains(String.valueOf(resource.getId()))) {
                 FlinkApplication app = applicationMap.get(flinkSql.getAppId());
                 if (!dependApplications.contains(app)) {
                     dependApplications.add(applicationMap.get(flinkSql.getAppId()));