You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/09/10 21:33:29 UTC
[incubator-streampark] branch dev updated: [Bug] Fix the bug about flink version don't be changed when flink home is changed (#1567)
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 <19...@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