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 9a2bf32b8b..4ca4d35141 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 @@ private List 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 flinkSqls = flinkSqlService.listByTeamId(resource.getTeamId()); for (FlinkSql flinkSql : flinkSqls) { String sqlTeamResource = flinkSql.getTeamResource();