[incubator-streampark] branch dev updated: [Bug] Fix the bug about flink version don't be changed when flink home is changed (#1567)

[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 160478c50 [Bug] Fix the bug about flink version don't be changed when 
flink home is changed (#1567)
160478c50 is described below

commit 160478c500836244ef41a72df1a406db016c1a26
Author: 1996fanrui <1996fan...@gmail.com>
AuthorDate: Sun Sep 11 05:33:21 2022 +0800

    [Bug] Fix the bug about flink version don't be changed when flink home is 
changed (#1567)
---
 .../streampark/console/core/service/impl/FlinkEnvServiceImpl.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 a30baca23..dbea94991 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
@@ -74,10 +74,10 @@ public class FlinkEnvServiceImpl extends 
ServiceImpl<FlinkEnvMapper, FlinkEnv> i
         if (!version.getFlinkHome().equals(flinkEnv.getFlinkHome())) {
             flinkEnv.setFlinkHome(version.getFlinkHome());
             flinkEnv.doSetFlinkConf();
-            version.doSetVersion();
+            flinkEnv.doSetVersion();
         }
         updateById(flinkEnv);
-        FlinkTrackingTask.getFlinkEnvMap().put(flinkEnv.getId(), version);
+        FlinkTrackingTask.getFlinkEnvMap().put(flinkEnv.getId(), flinkEnv);
     }
 
     @Override