[incubator-streampark] branch dev updated: [Bug] Flink cluster cannot modify the flink version #1992 (#1993)

[be...@apache.org]

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 d107ff99c [Bug] Flink cluster cannot modify the flink version #1992 (#1993)
d107ff99c is described below

commit d107ff99cbfd2fdbb7d79ccc9ac28c61f28aea40
Author: xujiangfeng001 <10...@users.noreply.github.com>
AuthorDate: Wed Nov 9 15:35:23 2022 +0800

    [Bug] Flink cluster cannot modify the flink version #1992 (#1993)
---
 .../streampark/console/core/controller/FlinkClusterController.java       | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
index 0da5a0b5d..2d1f8fac9 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
@@ -73,6 +73,7 @@ public class FlinkClusterController {
     public RestResponse update(FlinkCluster cluster) {
         FlinkCluster flinkCluster = flinkClusterService.getById(cluster.getId());
         flinkCluster.setClusterId(cluster.getClusterId());
+        flinkCluster.setVersionId(cluster.getVersionId());
         flinkCluster.setClusterName(cluster.getClusterName());
         flinkCluster.setAddress(cluster.getAddress());
         flinkCluster.setExecutionMode(cluster.getExecutionMode());