This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch session-cluster in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit 452929131255efb5bbea3a41bba571f42813df0c Author: benjobs <[email protected]> AuthorDate: Sat Nov 26 02:04:16 2022 +0800 [Improve] drop column flame_graph in t_flink_cluster --- .../src/assembly/script/schema/mysql-schema.sql | 1 - .../src/assembly/script/schema/pgsql-schema.sql | 1 - .../src/assembly/script/upgrade/mysql/2.0.0.sql | 4 +++- .../streampark-console-service/src/main/resources/db/schema-h2.sql | 1 - .../src/main/resources/mapper/core/FlinkClusterMapper.xml | 1 - 5 files changed, 3 insertions(+), 5 deletions(-) diff --git a/streampark-console/streampark-console-service/src/assembly/script/schema/mysql-schema.sql b/streampark-console/streampark-console-service/src/assembly/script/schema/mysql-schema.sql index dbc244896..dda27ac56 100644 --- a/streampark-console/streampark-console-service/src/assembly/script/schema/mysql-schema.sql +++ b/streampark-console/streampark-console-service/src/assembly/script/schema/mysql-schema.sql @@ -461,7 +461,6 @@ create table `t_flink_cluster` ( `dynamic_properties` text comment 'allows specifying multiple generic configuration options', `k8s_rest_exposed_type` tinyint default 2 comment 'k8s export(0:loadbalancer,1:clusterip,2:nodeport)', `k8s_hadoop_integration` tinyint default 0, - `flame_graph` tinyint default 0 comment 'flameGraph enableļ¼default disable', `k8s_conf` varchar(255) default null comment 'the path where the k8s configuration file is located', `resolve_order` int default null, `exception` text comment 'exception information', diff --git a/streampark-console/streampark-console-service/src/assembly/script/schema/pgsql-schema.sql b/streampark-console/streampark-console-service/src/assembly/script/schema/pgsql-schema.sql index 38ec0c479..ecefb7de6 100644 --- a/streampark-console/streampark-console-service/src/assembly/script/schema/pgsql-schema.sql +++ b/streampark-console/streampark-console-service/src/assembly/script/schema/pgsql-schema.sql @@ -311,7 +311,6 @@ create table "public"."t_flink_cluster" ( "dynamic_properties" text collate "pg_catalog"."default", "k8s_rest_exposed_type" int2 default 2, "k8s_hadoop_integration" boolean default false, - "flame_graph" boolean default false, "k8s_conf" varchar(255) collate "pg_catalog"."default", "resolve_order" int4, "exception" text collate "pg_catalog"."default", diff --git a/streampark-console/streampark-console-service/src/assembly/script/upgrade/mysql/2.0.0.sql b/streampark-console/streampark-console-service/src/assembly/script/upgrade/mysql/2.0.0.sql index 888325aee..872dee223 100644 --- a/streampark-console/streampark-console-service/src/assembly/script/upgrade/mysql/2.0.0.sql +++ b/streampark-console/streampark-console-service/src/assembly/script/upgrade/mysql/2.0.0.sql @@ -79,7 +79,9 @@ alter table `t_flink_project` add column `modify_time` datetime not null default current_timestamp on update current_timestamp after `create_time`, add index `inx_team` (`team_id`) using btree; -alter table `t_flink_cluster` add column `dynamic_properties` text comment 'allows specifying multiple generic configuration options' after `flink_image`; +alter table `t_flink_cluster` + drop column `flame_graph`, + add column `dynamic_properties` text comment 'allows specifying multiple generic configuration options' after `flink_image`; -- change `update_time` to `modify_time` alter table `t_app_build_pipe` change column `update_time` `modify_time` datetime not null default current_timestamp on update current_timestamp; diff --git a/streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql b/streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql index 2d54fe758..5cf0f13f8 100644 --- a/streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql +++ b/streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql @@ -409,7 +409,6 @@ create table if not exists `t_flink_cluster` ( `dynamic_properties` text comment 'allows specifying multiple generic configuration options', `k8s_rest_exposed_type` tinyint default 2 comment 'k8s export(0:loadbalancer,1:clusterip,2:nodeport)', `k8s_hadoop_integration` tinyint default 0, - `flame_graph` tinyint default 0 comment 'flameGraph enableļ¼default disable', `k8s_conf` varchar(255) default null comment 'the path where the k 8 s configuration file is located', `resolve_order` tinyint default null, `exception` text comment 'exception information', diff --git a/streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml b/streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml index e22a44869..c459c4b72 100644 --- a/streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml +++ b/streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml @@ -36,7 +36,6 @@ <result column="dynamic_properties" jdbcType="LONGVARCHAR" property="dynamicProperties"/> <result column="k8s_rest_exposed_type" jdbcType="TINYINT" property="k8sRestExposedType"/> <result column="k8s_hadoop_integration" jdbcType="BOOLEAN" property="k8sHadoopIntegration"/> - <result column="flame_graph" jdbcType="BOOLEAN" property="flameGraph"/> <result column="k8s_conf" jdbcType="VARCHAR" property="k8sConf"/> <result column="resolve_order" jdbcType="INTEGER" property="resolveOrder"/> <result column="exception" jdbcType="LONGVARCHAR" property="exception"/>
