This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch flink-119 in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit 1bfdafa3d38271e103d2a95f1b4c41d634b16779 Author: benjobs <[email protected]> AuthorDate: Fri Apr 19 15:43:36 2024 +0800 [Improve] 2.1.4 upgrade sql bug fixed. --- .../src/main/assembly/script/upgrade/mysql/2.1.4.sql | 2 +- .../src/main/assembly/script/upgrade/pgsql/2.1.4.sql | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.4.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.4.sql index 04b7f6ea4..33607f396 100644 --- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.4.sql +++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.4.sql @@ -27,7 +27,7 @@ SET a.`flink_cluster_id` = c.`id`; UPDATE `t_flink_app` SET `cluster_id` = `app_id` -WHERE `execution_mode` IN (2,3,5); +WHERE `execution_mode` IN (2,3,4); ALTER TABLE `t_flink_app` DROP COLUMN `app_id`; diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.4.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.4.sql index 6b216e6ec..6e6668214 100644 --- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.4.sql +++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.4.sql @@ -23,6 +23,6 @@ WHERE t_flink_app.cluster_id = t_flink_cluster.cluster_id UPDATE t_flink_app SET cluster_id = app_id -WHERE execution_mode IN (2,3,5); +WHERE execution_mode IN (2,3,4); ALTER TABLE t_flink_app DROP COLUMN app_id;
