(incubator-streampark) branch dev updated: [ISSUES-3627] doSetFlinkConf and doSetVersion are changed in sequence (#3636)

[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 028cbf303 [ISSUES-3627] doSetFlinkConf and doSetVersion are changed in 
sequence (#3636)
028cbf303 is described below

commit 028cbf3039496eba8f95c4babd3507c27dec5872
Author: hackallan <qhacke...@163.com>
AuthorDate: Wed Mar 27 15:08:14 2024 +0800

    [ISSUES-3627] doSetFlinkConf and doSetVersion are changed in sequence 
(#3636)
    
    * Added flink conf compatibility, flink-conf.yaml changed to conf.yaml 
after flink 1.19
    
    * Added flink conf compatibility, flink-conf.yaml changed to config.yaml  
after flink 1.19
    
    * Added flink conf compatibility, flink-conf.yaml changed to config.yaml  
after flink 1.19
    
    * Added flink conf compatibility, flink-conf.yaml changed to config.yaml  
after flink 1.19
    
    * Added flink conf compatibility, flink-conf.yaml changed to config.yaml  
after flink 1.19
    
    ---------
    
    Co-authored-by: qinjiyong <qinjiy...@jorme.sg>
---
 .../streampark/console/core/service/impl/FlinkEnvServiceImpl.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/FlinkEnvServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
index 86fef8010..17f41f5a5 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
@@ -88,8 +88,8 @@ public class FlinkEnvServiceImpl extends 
ServiceImpl<FlinkEnvMapper, FlinkEnv>
     long count = this.baseMapper.selectCount(null);
     version.setIsDefault(count == 0);
     version.setCreateTime(new Date());
-    version.doSetFlinkConf();
     version.doSetVersion();
+    version.doSetFlinkConf();
     return save(version);
   }