(incubator-streampark) branch dev updated: [Bug] Fails to modify program main class of resource (#3816)

[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 e7b50412c [Bug] Fails to modify program main class of resource (#3816)
e7b50412c is described below

commit e7b50412cc05ef774566571fb16b490d28e23e84
Author: yaolei <leisure2...@163.com>
AuthorDate: Sat Jun 29 00:23:15 2024 +0800

    [Bug] Fails to modify program main class of resource (#3816)
    
    Co-authored-by: benjobs <benj...@apache.org>
---
 .../streampark/console/core/service/impl/ResourceServiceImpl.java      | 3 +++
 1 file changed, 3 insertions(+)

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 886af7b77..843e25560 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
@@ -208,6 +208,9 @@ public class ResourceServiceImpl extends 
ServiceImpl<ResourceMapper, Resource>
       }
     }
 
+    if (resource.getResourceType() == ResourceTypeEnum.FLINK_APP) {
+      findResource.setMainClass(resource.getMainClass());
+    }
     findResource.setDescription(resource.getDescription());
     baseMapper.updateById(findResource);
   }