From 3a44fe02459d8aef6d287783c3056db38117c8dc Mon Sep 17 00:00:00 2001 From: Happy-shi <1900022824@pku.edu.cn> Date: Fri, 1 Nov 2024 22:42:30 +0800 Subject: [PATCH] [Bug]Fix jar library with task dependencies can be successfully deleted (#4124) Co-authored-by: Zhiwei Shi --- .../console/core/service/impl/ResourceServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 9ca1ea7750..9a2bf32b8b 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 @@ -497,7 +497,7 @@ private List 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()));