You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampark.apache.org by "Al-assad (via GitHub)" <gi...@apache.org> on 2023/04/22 08:50:05 UTC
[GitHub] [incubator-streampark] Al-assad commented on a diff in pull request #2680: [Improve] ddl schema column length improvement
Al-assad commented on code in PR #2680:
URL: https://github.com/apache/incubator-streampark/pull/2680#discussion_r1174336547
##########
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql:
##########
@@ -57,16 +57,16 @@ create table `t_flink_app` (
`options` text collate utf8mb4_general_ci,
`hot_params` text collate utf8mb4_general_ci,
`user_id` bigint default null,
- `app_id` varchar(255) collate utf8mb4_general_ci default null,
+ `app_id` varchar(64) collate utf8mb4_general_ci default null,
`app_type` tinyint default null,
`duration` bigint default null,
`job_id` varchar(64) collate utf8mb4_general_ci default null,
`job_manager_url` varchar(255) collate utf8mb4_general_ci default null,
`version_id` bigint default null,
- `cluster_id` varchar(255) collate utf8mb4_general_ci default null,
- `k8s_namespace` varchar(255) collate utf8mb4_general_ci default null,
- `flink_image` varchar(255) collate utf8mb4_general_ci default null,
- `state` varchar(50) collate utf8mb4_general_ci default null,
+ `cluster_id` varchar(64) collate utf8mb4_general_ci default null,
+ `k8s_namespace` varchar(64) collate utf8mb4_general_ci default null,
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql:
##########
@@ -274,17 +271,17 @@ create sequence "public"."streampark_t_flink_cluster_id_seq"
create table "public"."t_flink_cluster" (
"id" int8 not null default nextval('streampark_t_flink_cluster_id_seq'::regclass),
"address" varchar(150) collate "pg_catalog"."default",
- "cluster_id" varchar(100) collate "pg_catalog"."default",
- "cluster_name" varchar(100) collate "pg_catalog"."default" not null,
+ "cluster_id" varchar(128) collate "pg_catalog"."default",
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql:
##########
@@ -36,18 +36,92 @@ create table `t_yarn_queue` (
`id` bigint not null primary key auto_increment comment 'queue id',
`team_id` bigint not null comment 'team id',
`queue_label` varchar(128) collate utf8mb4_general_ci not null comment 'queue and label expression',
- `description` varchar(256) collate utf8mb4_general_ci default null comment 'description of the queue label',
+ `description` varchar(255) collate utf8mb4_general_ci default null comment 'description of the queue label',
`create_time` datetime not null default current_timestamp comment 'create time',
`modify_time` datetime not null default current_timestamp on update current_timestamp comment 'modify time',
unique key `unq_team_id_queue_label` (`team_id`, `queue_label`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
drop table if exists t_flink_tutorial;
-alter table `t_user` add column `login_type` tinyint default 0 after `user_type`;
-alter table `t_flink_app` change column `launch` `release` tinyint default 1;
-alter table `t_flink_log` add column `option_name` tinyint default null;
-alter table `t_flink_savepoint` modify column `path` varchar(1024) collate utf8mb4_general_ci default null;
+-- type change
+alter table `t_app_backup` modify column `path` varchar(128) collate utf8mb4_general_ci default null;
+
+alter table `t_flink_app`
+ change column `launch` `release` tinyint default 1,
+ modify column `project_id` bigint default null,
+ modify column `app_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `cluster_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `k8s_namespace` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `flink_image` varchar(128) collate utf8mb4_general_ci default null,
+ modify column `state` int default null,
+ drop index `inx_state`;
+
+alter table `t_flink_env`
+ modify column `version` varchar(64) collate utf8mb4_general_ci not null comment 'flink version',
+ modify column `scala_version` varchar(64) collate utf8mb4_general_ci not null comment 'scala version of flink';
+
+alter table `t_flink_log`
+ modify column `yarn_app_id` varchar(64) collate utf8mb4_general_ci default null,
+ add column `option_name` tinyint default null;
+
+alter table `t_flink_project`
+ modify column `url` varchar(255) collate utf8mb4_general_ci default null,
+ modify column `branches` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `user_name` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `password` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `prvkey_path` varchar(128) collate utf8mb4_general_ci default null;
+
+alter table `t_flink_savepoint`
+ modify column `path` varchar(255) collate utf8mb4_general_ci default null;
+
+
+alter table `t_menu`
+ modify column `menu_name` varchar(64) collate utf8mb4_general_ci not null comment 'menu button name',
+ modify column `path` varchar(64) collate utf8mb4_general_ci default null comment 'routing path',
+ modify column `component` varchar(64) collate utf8mb4_general_ci default null comment 'routing component component',
+ modify column `perms` varchar(64) collate utf8mb4_general_ci default null comment 'authority id',
+ modify column `icon` varchar(64) collate utf8mb4_general_ci default null comment 'icon';
+
+alter table `t_team`
+ modify column `team_name` varchar(64) collate utf8mb4_general_ci not null comment 'team name';
+
+alter table `t_variable`
+ modify column `variable_code` varchar(128) collate utf8mb4_general_ci not null comment 'Variable code is used for parameter names passed to the program or as placeholders';
+
+alter table `t_role`
+ modify column `role_name` varchar(64) collate utf8mb4_general_ci not null comment 'role name',
+ change column `remark` `description` varchar(255) collate utf8mb4_general_ci default null comment 'description',
+ drop column `role_code`;
+
+alter table `t_setting`
+ modify column `setting_key` varchar(64) collate utf8mb4_general_ci not null,
+ modify column `setting_name` varchar(255) collate utf8mb4_general_ci default null;
+
+alter table `t_user`
+ modify column `username` varchar(64) collate utf8mb4_general_ci not null comment 'user name',
+ modify column `nick_name` varchar(64) collate utf8mb4_general_ci not null comment 'nick name',
+ modify column `salt` varchar(32) collate utf8mb4_general_ci default null comment 'salt',
+ modify column `password` varchar(64) collate utf8mb4_general_ci not null comment 'password',
+ modify column `email` varchar(64) collate utf8mb4_general_ci default null comment 'email',
+ modify column `description` varchar(255) collate utf8mb4_general_ci default null comment 'description',
+ add column `login_type` tinyint default 0 after `user_type`,
+ drop column `avatar`;
+
+alter table `t_flink_cluster`
+ modify column `cluster_id` varchar(128) default null comment 'clusterid of session mode(yarn-session:application-id,k8s-session:cluster-id)',
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql:
##########
@@ -50,16 +50,16 @@ create table if not exists `t_flink_app` (
`options` text,
`hot_params` text ,
`user_id` bigint default null,
- `app_id` varchar(255) default null,
+ `app_id` varchar(64) default null,
`app_type` tinyint default null,
`duration` bigint default null,
`job_id` varchar(64) default null,
`job_manager_url` varchar(255) default null,
`version_id` bigint default null,
- `cluster_id` varchar(255) default null,
- `k8s_namespace` varchar(255) default null,
- `flink_image` varchar(255) default null,
- `state` varchar(50) default null,
+ `cluster_id` varchar(64) default null,
+ `k8s_namespace` varchar(64) default null,
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql:
##########
@@ -36,18 +36,92 @@ create table `t_yarn_queue` (
`id` bigint not null primary key auto_increment comment 'queue id',
`team_id` bigint not null comment 'team id',
`queue_label` varchar(128) collate utf8mb4_general_ci not null comment 'queue and label expression',
- `description` varchar(256) collate utf8mb4_general_ci default null comment 'description of the queue label',
+ `description` varchar(255) collate utf8mb4_general_ci default null comment 'description of the queue label',
`create_time` datetime not null default current_timestamp comment 'create time',
`modify_time` datetime not null default current_timestamp on update current_timestamp comment 'modify time',
unique key `unq_team_id_queue_label` (`team_id`, `queue_label`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
drop table if exists t_flink_tutorial;
-alter table `t_user` add column `login_type` tinyint default 0 after `user_type`;
-alter table `t_flink_app` change column `launch` `release` tinyint default 1;
-alter table `t_flink_log` add column `option_name` tinyint default null;
-alter table `t_flink_savepoint` modify column `path` varchar(1024) collate utf8mb4_general_ci default null;
+-- type change
+alter table `t_app_backup` modify column `path` varchar(128) collate utf8mb4_general_ci default null;
+
+alter table `t_flink_app`
+ change column `launch` `release` tinyint default 1,
+ modify column `project_id` bigint default null,
+ modify column `app_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `cluster_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `k8s_namespace` varchar(64) collate utf8mb4_general_ci default null,
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql:
##########
@@ -57,16 +57,16 @@ create table `t_flink_app` (
`options` text collate utf8mb4_general_ci,
`hot_params` text collate utf8mb4_general_ci,
`user_id` bigint default null,
- `app_id` varchar(255) collate utf8mb4_general_ci default null,
+ `app_id` varchar(64) collate utf8mb4_general_ci default null,
`app_type` tinyint default null,
`duration` bigint default null,
`job_id` varchar(64) collate utf8mb4_general_ci default null,
`job_manager_url` varchar(255) collate utf8mb4_general_ci default null,
`version_id` bigint default null,
- `cluster_id` varchar(255) collate utf8mb4_general_ci default null,
- `k8s_namespace` varchar(255) collate utf8mb4_general_ci default null,
- `flink_image` varchar(255) collate utf8mb4_general_ci default null,
- `state` varchar(50) collate utf8mb4_general_ci default null,
+ `cluster_id` varchar(64) collate utf8mb4_general_ci default null,
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql:
##########
@@ -205,15 +205,15 @@ create table "public"."t_flink_app" (
"options" text collate "pg_catalog"."default",
"hot_params" text collate "pg_catalog"."default",
"user_id" int8,
- "app_id" varchar(255) collate "pg_catalog"."default",
+ "app_id" varchar(64) collate "pg_catalog"."default",
"app_type" int2,
"duration" int8,
"job_id" varchar(64) collate "pg_catalog"."default",
"job_manager_url" varchar(255) collate "pg_catalog"."default",
"version_id" int8,
- "cluster_id" varchar(255) collate "pg_catalog"."default",
- "k8s_namespace" varchar(255) collate "pg_catalog"."default",
- "flink_image" varchar(255) collate "pg_catalog"."default",
+ "cluster_id" varchar(64) collate "pg_catalog"."default",
+ "k8s_namespace" varchar(64) collate "pg_catalog"."default",
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql:
##########
@@ -205,15 +205,15 @@ create table "public"."t_flink_app" (
"options" text collate "pg_catalog"."default",
"hot_params" text collate "pg_catalog"."default",
"user_id" int8,
- "app_id" varchar(255) collate "pg_catalog"."default",
+ "app_id" varchar(64) collate "pg_catalog"."default",
"app_type" int2,
"duration" int8,
"job_id" varchar(64) collate "pg_catalog"."default",
"job_manager_url" varchar(255) collate "pg_catalog"."default",
"version_id" int8,
- "cluster_id" varchar(255) collate "pg_catalog"."default",
- "k8s_namespace" varchar(255) collate "pg_catalog"."default",
- "flink_image" varchar(255) collate "pg_catalog"."default",
+ "cluster_id" varchar(64) collate "pg_catalog"."default",
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql:
##########
@@ -54,12 +52,93 @@ comment on column "public"."t_yarn_queue"."modify_time" is 'modify time';
alter table "public"."t_yarn_queue" add constraint "t_yarn_queue_pkey" primary key ("id");
alter table "public"."t_yarn_queue" add constraint "unique_team_id_queue_label" unique("team_id", "queue_label");
-alter table "public"."t_flink_log" add column "option_name" int2;
-alter table "public"."t_user" add column "login_type" int2 default 0;
-ALTER TABLE public.t_flink_app ALTER COLUMN state TYPE int4 USING state::int4;
+
drop table if exists "public"."t_flink_tutorial";
+-- type change
+alter table "public"."t_app_backup" modify column "path" varchar(128) collate utf8mb4_general_ci default null;
+
+alter table "public"."t_flink_app"
+ rename column "launch" to "release",
+ alter column "state" TYPE int4 USING state::int4;
+ alter column "app_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "cluster_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "k8s_namespace" TYPE varchar(64) collate "pg_catalog"."default",
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql:
##########
@@ -54,12 +52,93 @@ comment on column "public"."t_yarn_queue"."modify_time" is 'modify time';
alter table "public"."t_yarn_queue" add constraint "t_yarn_queue_pkey" primary key ("id");
alter table "public"."t_yarn_queue" add constraint "unique_team_id_queue_label" unique("team_id", "queue_label");
-alter table "public"."t_flink_log" add column "option_name" int2;
-alter table "public"."t_user" add column "login_type" int2 default 0;
-ALTER TABLE public.t_flink_app ALTER COLUMN state TYPE int4 USING state::int4;
+
drop table if exists "public"."t_flink_tutorial";
+-- type change
+alter table "public"."t_app_backup" modify column "path" varchar(128) collate utf8mb4_general_ci default null;
+
+alter table "public"."t_flink_app"
+ rename column "launch" to "release",
+ alter column "state" TYPE int4 USING state::int4;
+ alter column "app_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "cluster_id" TYPE varchar(64) collate "pg_catalog"."default",
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql:
##########
@@ -54,12 +52,93 @@ comment on column "public"."t_yarn_queue"."modify_time" is 'modify time';
alter table "public"."t_yarn_queue" add constraint "t_yarn_queue_pkey" primary key ("id");
alter table "public"."t_yarn_queue" add constraint "unique_team_id_queue_label" unique("team_id", "queue_label");
-alter table "public"."t_flink_log" add column "option_name" int2;
-alter table "public"."t_user" add column "login_type" int2 default 0;
-ALTER TABLE public.t_flink_app ALTER COLUMN state TYPE int4 USING state::int4;
+
drop table if exists "public"."t_flink_tutorial";
+-- type change
+alter table "public"."t_app_backup" modify column "path" varchar(128) collate utf8mb4_general_ci default null;
+
+alter table "public"."t_flink_app"
+ rename column "launch" to "release",
+ alter column "state" TYPE int4 USING state::int4;
+ alter column "app_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "cluster_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "k8s_namespace" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "flink_image" TYPE varchar(128) collate "pg_catalog"."default";
+
+
+alter table "public"."t_flink_env"
+ alter column "version" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "scala_version" TYPE varchar(64) collate "pg_catalog"."default" not null;
+
+
+alter table "public"."t_flink_log"
+ alter column "yarn_app_id" TYPE varchar(64) collate "pg_catalog"."default",
+ add column "option_name" int2;
+
+
+alter table "public"."t_flink_project"
+ alter column "url" TYPE varchar(255) collate "pg_catalog"."default",
+ alter column "branches" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "user_name" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "password" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "prvkey_path" TYPE varchar(128) collate "pg_catalog"."default";
+
+
+alter table "public"."t_flink_savepoint"
+ alter column "path" TYPE varchar(255) collate "pg_catalog"."default";
+
+
+alter table "public"."t_menu"
+ alter column "menu_name" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "path" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "component" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "perms" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "icon" TYPE varchar(64) collate "pg_catalog"."default";
+
+alter table "public"."t_team"
+ alter column "team_name" TYPE varchar(64) collate "pg_catalog"."default" not null;
+
+alter table "public"."t_variable"
+ alter column "variable_code" TYPE varchar(128) collate "pg_catalog"."default" not null;
+
+alter table "public"."t_role"
+ alter column "role_name" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ rename column "remark" to "description",
+ drop column "role_code";
+
+alter table "public"."t_role"
+ alter column "description" TYPE varchar(255) collate "pg_catalog"."default";
+
+
+alter table "public"."t_setting"
+ alter column "setting_key" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "setting_value" TYPE text collate "pg_catalog"."default";
+
+alter table "public"."t_user"
+ alter column "username" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "nick_name" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "salt" TYPE varchar(32) collate "pg_catalog"."default" not null,
+ alter column "password" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "email" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "description" TYPE varchar(255) collate "pg_catalog"."default",
+ add column "login_type" TYPE int2 default 0;
+ drop column "avatar";
+
+alter table "public"."t_flink_cluster"
+ alter column "cluster_id" TYPE varchar(128) collate "pg_catalog"."default",
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql:
##########
@@ -54,12 +52,93 @@ comment on column "public"."t_yarn_queue"."modify_time" is 'modify time';
alter table "public"."t_yarn_queue" add constraint "t_yarn_queue_pkey" primary key ("id");
alter table "public"."t_yarn_queue" add constraint "unique_team_id_queue_label" unique("team_id", "queue_label");
-alter table "public"."t_flink_log" add column "option_name" int2;
-alter table "public"."t_user" add column "login_type" int2 default 0;
-ALTER TABLE public.t_flink_app ALTER COLUMN state TYPE int4 USING state::int4;
+
drop table if exists "public"."t_flink_tutorial";
+-- type change
+alter table "public"."t_app_backup" modify column "path" varchar(128) collate utf8mb4_general_ci default null;
+
+alter table "public"."t_flink_app"
+ rename column "launch" to "release",
+ alter column "state" TYPE int4 USING state::int4;
+ alter column "app_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "cluster_id" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "k8s_namespace" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "flink_image" TYPE varchar(128) collate "pg_catalog"."default";
+
+
+alter table "public"."t_flink_env"
+ alter column "version" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "scala_version" TYPE varchar(64) collate "pg_catalog"."default" not null;
+
+
+alter table "public"."t_flink_log"
+ alter column "yarn_app_id" TYPE varchar(64) collate "pg_catalog"."default",
+ add column "option_name" int2;
+
+
+alter table "public"."t_flink_project"
+ alter column "url" TYPE varchar(255) collate "pg_catalog"."default",
+ alter column "branches" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "user_name" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "password" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "prvkey_path" TYPE varchar(128) collate "pg_catalog"."default";
+
+
+alter table "public"."t_flink_savepoint"
+ alter column "path" TYPE varchar(255) collate "pg_catalog"."default";
+
+
+alter table "public"."t_menu"
+ alter column "menu_name" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "path" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "component" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "perms" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "icon" TYPE varchar(64) collate "pg_catalog"."default";
+
+alter table "public"."t_team"
+ alter column "team_name" TYPE varchar(64) collate "pg_catalog"."default" not null;
+
+alter table "public"."t_variable"
+ alter column "variable_code" TYPE varchar(128) collate "pg_catalog"."default" not null;
+
+alter table "public"."t_role"
+ alter column "role_name" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ rename column "remark" to "description",
+ drop column "role_code";
+
+alter table "public"."t_role"
+ alter column "description" TYPE varchar(255) collate "pg_catalog"."default";
+
+
+alter table "public"."t_setting"
+ alter column "setting_key" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "setting_value" TYPE text collate "pg_catalog"."default";
+
+alter table "public"."t_user"
+ alter column "username" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "nick_name" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "salt" TYPE varchar(32) collate "pg_catalog"."default" not null,
+ alter column "password" TYPE varchar(64) collate "pg_catalog"."default" not null,
+ alter column "email" TYPE varchar(64) collate "pg_catalog"."default",
+ alter column "description" TYPE varchar(255) collate "pg_catalog"."default",
+ add column "login_type" TYPE int2 default 0;
+ drop column "avatar";
+
+alter table "public"."t_flink_cluster"
+ alter column "cluster_id" TYPE varchar(128) collate "pg_catalog"."default",
+ alter column "cluster_name" TYPE varchar(128) collate "pg_catalog"."default" not null,
+ alter column "yarn_queue" TYPE varchar(128) collate "pg_catalog"."default",
+ alter column "k8s_namespace" TYPE varchar(64) collate "pg_catalog"."default",
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql:
##########
@@ -36,18 +36,92 @@ create table `t_yarn_queue` (
`id` bigint not null primary key auto_increment comment 'queue id',
`team_id` bigint not null comment 'team id',
`queue_label` varchar(128) collate utf8mb4_general_ci not null comment 'queue and label expression',
- `description` varchar(256) collate utf8mb4_general_ci default null comment 'description of the queue label',
+ `description` varchar(255) collate utf8mb4_general_ci default null comment 'description of the queue label',
`create_time` datetime not null default current_timestamp comment 'create time',
`modify_time` datetime not null default current_timestamp on update current_timestamp comment 'modify time',
unique key `unq_team_id_queue_label` (`team_id`, `queue_label`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
drop table if exists t_flink_tutorial;
-alter table `t_user` add column `login_type` tinyint default 0 after `user_type`;
-alter table `t_flink_app` change column `launch` `release` tinyint default 1;
-alter table `t_flink_log` add column `option_name` tinyint default null;
-alter table `t_flink_savepoint` modify column `path` varchar(1024) collate utf8mb4_general_ci default null;
+-- type change
+alter table `t_app_backup` modify column `path` varchar(128) collate utf8mb4_general_ci default null;
+
+alter table `t_flink_app`
+ change column `launch` `release` tinyint default 1,
+ modify column `project_id` bigint default null,
+ modify column `app_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `cluster_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `k8s_namespace` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `flink_image` varchar(128) collate utf8mb4_general_ci default null,
+ modify column `state` int default null,
+ drop index `inx_state`;
+
+alter table `t_flink_env`
+ modify column `version` varchar(64) collate utf8mb4_general_ci not null comment 'flink version',
+ modify column `scala_version` varchar(64) collate utf8mb4_general_ci not null comment 'scala version of flink';
+
+alter table `t_flink_log`
+ modify column `yarn_app_id` varchar(64) collate utf8mb4_general_ci default null,
+ add column `option_name` tinyint default null;
+
+alter table `t_flink_project`
+ modify column `url` varchar(255) collate utf8mb4_general_ci default null,
+ modify column `branches` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `user_name` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `password` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `prvkey_path` varchar(128) collate utf8mb4_general_ci default null;
+
+alter table `t_flink_savepoint`
+ modify column `path` varchar(255) collate utf8mb4_general_ci default null;
+
+
+alter table `t_menu`
+ modify column `menu_name` varchar(64) collate utf8mb4_general_ci not null comment 'menu button name',
+ modify column `path` varchar(64) collate utf8mb4_general_ci default null comment 'routing path',
+ modify column `component` varchar(64) collate utf8mb4_general_ci default null comment 'routing component component',
+ modify column `perms` varchar(64) collate utf8mb4_general_ci default null comment 'authority id',
+ modify column `icon` varchar(64) collate utf8mb4_general_ci default null comment 'icon';
+
+alter table `t_team`
+ modify column `team_name` varchar(64) collate utf8mb4_general_ci not null comment 'team name';
+
+alter table `t_variable`
+ modify column `variable_code` varchar(128) collate utf8mb4_general_ci not null comment 'Variable code is used for parameter names passed to the program or as placeholders';
+
+alter table `t_role`
+ modify column `role_name` varchar(64) collate utf8mb4_general_ci not null comment 'role name',
+ change column `remark` `description` varchar(255) collate utf8mb4_general_ci default null comment 'description',
+ drop column `role_code`;
+
+alter table `t_setting`
+ modify column `setting_key` varchar(64) collate utf8mb4_general_ci not null,
+ modify column `setting_name` varchar(255) collate utf8mb4_general_ci default null;
+
+alter table `t_user`
+ modify column `username` varchar(64) collate utf8mb4_general_ci not null comment 'user name',
+ modify column `nick_name` varchar(64) collate utf8mb4_general_ci not null comment 'nick name',
+ modify column `salt` varchar(32) collate utf8mb4_general_ci default null comment 'salt',
+ modify column `password` varchar(64) collate utf8mb4_general_ci not null comment 'password',
+ modify column `email` varchar(64) collate utf8mb4_general_ci default null comment 'email',
+ modify column `description` varchar(255) collate utf8mb4_general_ci default null comment 'description',
+ add column `login_type` tinyint default 0 after `user_type`,
+ drop column `avatar`;
+
+alter table `t_flink_cluster`
+ modify column `cluster_id` varchar(128) default null comment 'clusterid of session mode(yarn-session:application-id,k8s-session:cluster-id)',
+ modify column `cluster_name` varchar(128) not null comment 'cluster name',
+ modify column `options` text comment 'json form of parameter collection ',
+ modify column `yarn_queue` varchar(128) default null comment 'the yarn queue where the task is located',
+ modify column `k8s_namespace` varchar(64) default 'default' comment 'k8s namespace',
Review Comment:
Change to varchar(63)
##########
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql:
##########
@@ -36,18 +36,92 @@ create table `t_yarn_queue` (
`id` bigint not null primary key auto_increment comment 'queue id',
`team_id` bigint not null comment 'team id',
`queue_label` varchar(128) collate utf8mb4_general_ci not null comment 'queue and label expression',
- `description` varchar(256) collate utf8mb4_general_ci default null comment 'description of the queue label',
+ `description` varchar(255) collate utf8mb4_general_ci default null comment 'description of the queue label',
`create_time` datetime not null default current_timestamp comment 'create time',
`modify_time` datetime not null default current_timestamp on update current_timestamp comment 'modify time',
unique key `unq_team_id_queue_label` (`team_id`, `queue_label`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
drop table if exists t_flink_tutorial;
-alter table `t_user` add column `login_type` tinyint default 0 after `user_type`;
-alter table `t_flink_app` change column `launch` `release` tinyint default 1;
-alter table `t_flink_log` add column `option_name` tinyint default null;
-alter table `t_flink_savepoint` modify column `path` varchar(1024) collate utf8mb4_general_ci default null;
+-- type change
+alter table `t_app_backup` modify column `path` varchar(128) collate utf8mb4_general_ci default null;
+
+alter table `t_flink_app`
+ change column `launch` `release` tinyint default 1,
+ modify column `project_id` bigint default null,
+ modify column `app_id` varchar(64) collate utf8mb4_general_ci default null,
+ modify column `cluster_id` varchar(64) collate utf8mb4_general_ci default null,
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql:
##########
@@ -50,16 +50,16 @@ create table if not exists `t_flink_app` (
`options` text,
`hot_params` text ,
`user_id` bigint default null,
- `app_id` varchar(255) default null,
+ `app_id` varchar(64) default null,
`app_type` tinyint default null,
`duration` bigint default null,
`job_id` varchar(64) default null,
`job_manager_url` varchar(255) default null,
`version_id` bigint default null,
- `cluster_id` varchar(255) default null,
- `k8s_namespace` varchar(255) default null,
- `flink_image` varchar(255) default null,
- `state` varchar(50) default null,
+ `cluster_id` varchar(64) default null,
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql:
##########
@@ -373,17 +372,17 @@ create table if not exists `t_app_build_pipe` (
create table if not exists `t_flink_cluster` (
`id` bigint generated by default as identity not null,
`address` varchar(150) default null comment 'url address of jobmanager',
- `cluster_id` varchar(100) default null comment 'clusterId of session mode(yarn-session:application-id,k8s-session:cluster-id)',
- `cluster_name` varchar(100) not null comment 'cluster name',
+ `cluster_id` varchar(128) default null comment 'clusterId of session mode(yarn-session:application-id,k8s-session:cluster-id)',
Review Comment:
Change to varchar(45)
##########
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql:
##########
@@ -373,17 +372,17 @@ create table if not exists `t_app_build_pipe` (
create table if not exists `t_flink_cluster` (
`id` bigint generated by default as identity not null,
`address` varchar(150) default null comment 'url address of jobmanager',
- `cluster_id` varchar(100) default null comment 'clusterId of session mode(yarn-session:application-id,k8s-session:cluster-id)',
- `cluster_name` varchar(100) not null comment 'cluster name',
+ `cluster_id` varchar(128) default null comment 'clusterId of session mode(yarn-session:application-id,k8s-session:cluster-id)',
+ `cluster_name` varchar(128) not null comment 'cluster name',
`options` text comment 'json form of parameter collection ',
- `yarn_queue` varchar(100) default null comment 'the yarn queue where the task is located',
+ `yarn_queue` varchar(128) default null comment 'the yarn queue where the task is located',
`execution_mode` tinyint not null default 1 comment 'k8s execution session mode(1:remote,3:yarn-session,5:kubernetes-session)',
`version_id` bigint not null comment 'flink version id',
- `k8s_namespace` varchar(255) default 'default' comment 'k8s namespace',
- `service_account` varchar(50) default null comment 'k8s service account',
+ `k8s_namespace` varchar(64) default 'default' comment 'k8s namespace',
Review Comment:
Change to varchar(63)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@streampark.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org