(incubator-streampark) branch dev updated: [Bug]Fix jar library with task dependencies can be successfully deleted (#4124)

[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 3a44fe024 [Bug]Fix jar library with task dependencies can be 
successfully deleted (#4124)
3a44fe024 is described below

commit 3a44fe02459d8aef6d287783c3056db38117c8dc
Author: Happy-shi <1900022...@pku.edu.cn>
AuthorDate: Fri Nov 1 22:42:30 2024 +0800

    [Bug]Fix jar library with task dependencies can be successfully deleted 
(#4124)
    
    Co-authored-by: Zhiwei Shi <sh...@rd.netease.com>
---
 .../streampark/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 9ca1ea775..9a2bf32b8 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 @@ public class ResourceServiceImpl extends 
ServiceImpl<ResourceMapper, 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()));