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 92551170f [Improve] mysql ddl current_timestamp syntax compatibility
improvement (#3572)
92551170f is described below
commit 92551170f4ebc21e92b718ba168d6039bed7d829
Author: joyCurry30 <[email protected]>
AuthorDate: Thu Feb 29 15:56:03 2024 +0800
[Improve] mysql ddl current_timestamp syntax compatibility improvement
(#3572)
Co-authored-by: tianzhu.wen <[email protected]>
---
.../main/assembly/script/schema/mysql-schema.sql | 74 +++++++++++-----------
.../main/assembly/script/schema/pgsql-schema.sql | 70 ++++++++++----------
.../main/assembly/script/upgrade/mysql/2.0.0.sql | 38 +++++------
.../main/assembly/script/upgrade/mysql/2.1.0.sql | 9 +--
.../main/assembly/script/upgrade/mysql/2.2.0.sql | 8 +--
.../main/assembly/script/upgrade/pgsql/2.1.0.sql | 8 +--
.../main/assembly/script/upgrade/pgsql/2.2.0.sql | 8 +--
.../console/core/controller/SettingController.java | 7 --
.../console/core/entity/FlinkCluster.java | 2 +-
.../streampark/console/core/entity/Resource.java | 4 +-
.../streampark/console/core/entity/Variable.java | 4 +-
.../impl/ApplicationManageServiceImpl.java | 10 +--
.../core/service/impl/ExternalLinkServiceImpl.java | 5 +-
.../core/service/impl/ProjectServiceImpl.java | 4 +-
.../system/security/impl/AuthenticatorImpl.java | 4 +-
.../service/impl/AccessTokenServiceImpl.java | 4 +-
.../system/service/impl/MemberServiceImpl.java | 6 +-
.../system/service/impl/RoleServiceImpl.java | 4 +-
.../system/service/impl/TeamServiceImpl.java | 5 +-
.../system/service/impl/UserServiceImpl.java | 4 +-
.../src/main/resources/db/schema-h2.sql | 72 ++++++++++-----------
21 files changed, 180 insertions(+), 170 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
index a067c2e46..ac4e5f2dc 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
@@ -33,7 +33,7 @@ create table `t_app_backup` (
`version` int default null,
`path` varchar(128) collate utf8mb4_general_ci default null,
`description` varchar(255) collate utf8mb4_general_ci default null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -86,8 +86,8 @@ create table `t_flink_app` (
`available_slot` int default null,
`option_state` tinyint default null,
`tracking` tinyint default null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
- `modify_time` datetime not null default current_timestamp comment 'modify
time',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
`option_time` datetime default null,
`release` tinyint default 1,
`build` tinyint default 1,
@@ -122,7 +122,7 @@ create table `t_flink_config` (
`version` int not null,
`latest` tinyint not null default 0,
`content` text collate utf8mb4_general_ci not null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -136,7 +136,7 @@ create table `t_flink_effective` (
`app_id` bigint not null,
`target_type` tinyint not null comment '1) config 2) flink sql',
`target_id` bigint not null comment 'configid or sqlid',
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree,
unique key `un_effective_inx` (`app_id`,`target_type`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -155,7 +155,7 @@ create table `t_flink_env` (
`flink_conf` text collate utf8mb4_general_ci not null comment 'flink-conf',
`is_default` tinyint not null default 0 comment 'whether default version or
not',
`description` varchar(255) collate utf8mb4_general_ci default null comment
'description',
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree,
unique key `un_env_name` (`flink_name`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -198,8 +198,8 @@ create table `t_flink_project` (
`last_build` datetime default null,
`description` varchar(255) collate utf8mb4_general_ci default null,
`build_state` tinyint default -1,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
index `inx_team` (`team_id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -217,7 +217,7 @@ create table `t_flink_savepoint` (
`path` varchar(255) collate utf8mb4_general_ci default null,
`latest` tinyint not null default 1,
`trigger_time` datetime default null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -234,7 +234,7 @@ create table `t_flink_sql` (
`dependency` text collate utf8mb4_general_ci,
`version` int default null,
`candidate` tinyint not null default 1,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -254,8 +254,8 @@ create table `t_menu` (
`type` char(2) collate utf8mb4_general_ci default null comment 'type 0:menu
1:button',
`display` tinyint collate utf8mb4_general_ci not null default 1 comment
'whether the menu is displayed',
`order_num` int default null comment 'sort',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`menu_id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -272,7 +272,7 @@ create table `t_message` (
`title` varchar(255) collate utf8mb4_general_ci default null,
`context` text collate utf8mb4_general_ci,
`is_read` tinyint default 0,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key (`id`) using btree,
key `inx_mes_user` (`user_id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -286,8 +286,8 @@ create table `t_team` (
`id` bigint not null auto_increment comment 'team id',
`team_name` varchar(64) collate utf8mb4_general_ci not null comment 'team
name',
`description` varchar(255) collate utf8mb4_general_ci default null,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `team_name_idx` (`team_name`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
@@ -304,8 +304,8 @@ create table `t_variable` (
`creator_id` bigint collate utf8mb4_general_ci not null comment 'user id of
creator',
`team_id` bigint collate utf8mb4_general_ci not null comment 'team id',
`desensitization` tinyint not null default 0 comment '0 is no
desensitization, 1 is desensitization, if set to desensitization, it will be
replaced by * when displayed',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `un_team_vcode_inx` (`team_id`,`variable_code`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -324,8 +324,8 @@ create table `t_resource` (
`description` text collate utf8mb4_general_ci default null comment 'More
detailed description of resource',
`creator_id` bigint collate utf8mb4_general_ci not null comment 'user id of
creator',
`team_id` bigint collate utf8mb4_general_ci not null comment 'team id',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `un_team_vcode_inx` (`team_id`,`resource_name`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -337,8 +337,8 @@ drop table if exists `t_role`;
create table `t_role` (
`role_id` bigint not null auto_increment comment 'user id',
`role_name` varchar(64) collate utf8mb4_general_ci not null comment 'role
name',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
`description` varchar(255) collate utf8mb4_general_ci default null comment
'description',
primary key (`role_id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -387,8 +387,8 @@ create table `t_user` (
`login_type` tinyint default 0 comment 'login type 0:password 1:ldap 2:sso',
`last_team_id` bigint default null comment 'last team id',
`status` char(1) collate utf8mb4_general_ci not null comment 'status
0:locked 1:active',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
`last_login_time` datetime default null comment 'last login time',
`sex` char(1) collate utf8mb4_general_ci default null comment 'gender 0:male
1:female 2:confidential',
`avatar` varchar(128) collate utf8mb4_general_ci default null comment
'avatar',
@@ -407,8 +407,8 @@ create table `t_member` (
`team_id` bigint not null comment 'team id',
`user_id` bigint not null comment 'user id',
`role_id` bigint not null comment 'role id',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `un_user_team_role_inx` (`user_id`,`team_id`,`role_id`) using
btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -428,7 +428,7 @@ create table `t_app_build_pipe`(
`steps_status_ts` text,
`error` text,
`build_result` text,
- `modify_time` datetime not null default current_timestamp on update
current_timestamp comment 'modify time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`app_id`) using btree
) engine = innodb auto_increment=100000 default charset = utf8mb4 collate =
utf8mb4_general_ci;
@@ -459,7 +459,7 @@ create table `t_flink_cluster` (
`resolve_order` int default null,
`exception` text comment 'exception information',
`cluster_state` tinyint default 0 comment 'cluster status (0: created but
not started, 1: started, 2: stopped)',
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
`start_time` datetime default null comment 'start time',
`end_time` datetime default null comment 'end time',
`alert_id` bigint default null comment 'alert id',
@@ -479,8 +479,8 @@ create table `t_access_token` (
`expire_time` datetime default null comment 'expiration',
`description` varchar(255) character set utf8mb4 collate utf8mb4_general_ci
default null comment 'description',
`status` tinyint default null comment '1:enable,0:disable',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -500,8 +500,8 @@ create table `t_alert_config` (
`we_com_params` varchar(255) collate utf8mb4_general_ci comment 'wechat
params',
`http_callback_params` text collate utf8mb4_general_ci comment 'http
callback params',
`lark_params` text collate utf8mb4_general_ci comment 'lark params',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
index `inx_alert_user` (`user_id`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
@@ -515,8 +515,8 @@ CREATE TABLE `t_external_link` (
`badge_name` varchar(64) collate utf8mb4_general_ci default null,
`badge_color` varchar(64) collate utf8mb4_general_ci default null,
`link_url` varchar(255) collate utf8mb4_general_ci default null,
- `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'
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'modify
time'
) engine = innodb default charset=utf8mb4 collate=utf8mb4_general_ci;
-- ----------------------------
@@ -528,8 +528,8 @@ create table `t_yarn_queue` (
`team_id` bigint not null comment 'team id',
`queue_label` varchar(128) collate utf8mb4_general_ci not null comment
'queue label expression',
`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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null 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;
@@ -552,8 +552,8 @@ create table if not exists `t_resource` (
`connector_required_options` text default null,
`connector_optional_options` text default null,
`team_id` bigint not null comment 'team id',
-`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'
+`create_time` datetime default null comment 'create time',
+`modify_time` datetime not null default current_timestamp comment 'modify time'
);
set foreign_key_checks = 1;
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
index b0888bbe6..3b4608b1b 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
@@ -95,8 +95,8 @@ create table "public"."t_access_token" (
"expire_time" timestamp(6),
"description" varchar(255) collate "pg_catalog"."default",
"status" int2,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
);
comment on column "public"."t_access_token"."id" is 'key';
comment on column "public"."t_access_token"."token" is 'token';
@@ -125,8 +125,8 @@ create table "public"."t_alert_config" (
"we_com_params" varchar(255) collate "pg_catalog"."default",
"http_callback_params" text collate "pg_catalog"."default",
"lark_params" text collate "pg_catalog"."default",
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_alert_config"."alert_name" is 'alert name';
@@ -159,7 +159,7 @@ create table "public"."t_app_backup" (
"version" int4,
"path" varchar(128) collate "pg_catalog"."default",
"description" varchar(255) collate "pg_catalog"."default",
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
alter table "public"."t_app_backup" add constraint "t_app_backup_pkey" primary
key ("id");
@@ -178,7 +178,7 @@ create table "public"."t_app_build_pipe" (
"steps_status_ts" text collate "pg_catalog"."default",
"error" text collate "pg_catalog"."default",
"build_result" text collate "pg_catalog"."default",
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "modify_time" timestamp(6)
)
;
alter table "public"."t_app_build_pipe" add constraint "t_app_build_pipe_pkey"
primary key ("app_id");
@@ -234,8 +234,8 @@ create table "public"."t_flink_app" (
"available_slot" int4,
"option_state" int2,
"tracking" int2,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6),
"option_time" timestamp(6),
"release" int2 default 1,
"build" boolean default true,
@@ -293,7 +293,7 @@ create table "public"."t_flink_cluster" (
"resolve_order" int4,
"exception" text collate "pg_catalog"."default",
"cluster_state" int2 default 0,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
+ "create_time" timestamp(6),
"start_time" timestamp(6),
"end_time" timestamp(6),
"alert_id" int8
@@ -339,7 +339,7 @@ create table "public"."t_flink_config" (
"version" int4 not null,
"latest" boolean not null default false,
"content" text collate "pg_catalog"."default" not null,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
alter table "public"."t_flink_config" add constraint "t_flink_config_pkey"
primary key ("id");
@@ -356,7 +356,7 @@ create table "public"."t_flink_effective" (
"app_id" int8 not null,
"target_type" int2 not null,
"target_id" int8 not null,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
comment on column "public"."t_flink_effective"."target_type" is '1) config 2)
flink sql';
@@ -383,7 +383,7 @@ create table "public"."t_flink_env" (
"flink_conf" text collate "pg_catalog"."default" not null,
"is_default" boolean not null default false,
"description" varchar(255) collate "pg_catalog"."default",
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
comment on column "public"."t_flink_env"."id" is 'id';
@@ -443,8 +443,8 @@ create table "public"."t_flink_project" (
"last_build" timestamp(6),
"description" varchar(255) collate "pg_catalog"."default",
"build_state" int2 default -1,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
alter table "public"."t_flink_project" add constraint "t_flink_project_pkey"
primary key ("id");
@@ -467,7 +467,7 @@ create table "public"."t_flink_savepoint" (
"path" varchar(255) collate "pg_catalog"."default",
"latest" boolean not null default true,
"trigger_time" timestamp(6),
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
alter table "public"."t_flink_savepoint" add constraint
"t_flink_savepoint_pkey" primary key ("id");
@@ -487,7 +487,7 @@ create table "public"."t_flink_sql" (
"dependency" text collate "pg_catalog"."default",
"version" int4,
"candidate" int2 default 1 not null,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
alter table "public"."t_flink_sql" add constraint "t_flink_sql_pkey" primary
key ("id");
@@ -510,8 +510,8 @@ create table "public"."t_menu" (
"type" int2,
"display" boolean not null default true,
"order_num" float8,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_menu"."menu_id" is 'menu button id';
@@ -543,7 +543,7 @@ create table "public"."t_message" (
"title" varchar(255) collate "pg_catalog"."default",
"context" text collate "pg_catalog"."default",
"is_read" boolean default false,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6)
)
;
alter table "public"."t_message" add constraint "t_message_pkey" primary key
("id");
@@ -563,8 +563,8 @@ create table "public"."t_team" (
"id" int8 not null default nextval('streampark_t_team_id_seq'::regclass),
"team_name" varchar(64) collate "pg_catalog"."default" not null,
"description" varchar(255) collate "pg_catalog"."default" default null,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_team"."id" is 'team id';
@@ -590,8 +590,8 @@ create table "public"."t_variable" (
"creator_id" int8 not null,
"team_id" int8 not null,
"desensitization" boolean not null default false,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_variable"."id" is 'variable id';
@@ -629,8 +629,8 @@ create table "public"."t_resource" (
"connector_required_options" text
default null,
"connector_optional_options" text
default null,
"team_id" int8 not null,
- "create_time" timestamp(6) not null
default timezone('UTC-8'::text, (now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null
default timezone('UTC-8'::text, (now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_resource"."id" is 'Resource id';
@@ -660,8 +660,8 @@ create sequence "public"."streampark_t_role_id_seq"
create table "public"."t_role" (
"role_id" int8 not null default
nextval('streampark_t_role_id_seq'::regclass),
"role_name" varchar(64) collate "pg_catalog"."default" not null,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6),
"description" varchar(255) collate "pg_catalog"."default"
)
;
@@ -724,8 +724,8 @@ create table "public"."t_user" (
"login_type" int2 default 0,
"last_team_id" int8,
"status" int2,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6),
"last_login_time" timestamp(6),
"sex" char(1) collate "pg_catalog"."default",
"avatar" varchar(128) collate "pg_catalog"."default",
@@ -765,8 +765,8 @@ create table "public"."t_member" (
"team_id" int8,
"user_id" int8,
"role_id" int8,
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_member"."team_id" is 'team id';
@@ -792,8 +792,8 @@ create table "public"."t_external_link" (
"badge_name" varchar(64) collate "pg_catalog"."default",
"badge_color" varchar(64) collate "pg_catalog"."default",
"link_url" varchar(255) collate "pg_catalog"."default",
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone))
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6))
;
alter table "public"."t_external_link" add constraint "t_external_link_pkey"
primary key ("id");
@@ -809,8 +809,8 @@ create table "public"."t_yarn_queue" (
"team_id" int8 not null,
"queue_label" varchar(128) not null collate "pg_catalog"."default",
"description" varchar(255) collate "pg_catalog"."default",
- "create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
- "modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+ "create_time" timestamp(6),
+ "modify_time" timestamp(6)
)
;
comment on column "public"."t_yarn_queue"."id" is 'queue id';
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
index de4e88c82..19f15c213 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
@@ -23,7 +23,7 @@ set foreign_key_checks = 0;
drop table if exists `t_alert_config`;
create table `t_alert_config` (
`id` bigint not null auto_increment primary key,
- `user_id` bigint default null,
+ `user_id` bigint default null,
`alert_name` varchar(128) collate utf8mb4_general_ci default null comment
'alert group name',
`alert_type` int default 0 comment 'alert type',
`email_params` varchar(255) collate utf8mb4_general_ci comment 'email
params',
@@ -32,8 +32,8 @@ create table `t_alert_config` (
`we_com_params` varchar(255) collate utf8mb4_general_ci comment 'wechat
params',
`http_callback_params` text collate utf8mb4_general_ci comment 'http
callback params',
`lark_params` text collate utf8mb4_general_ci comment 'lark params',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
index `inx_user_id` (`user_id`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
@@ -67,7 +67,7 @@ alter table `t_flink_app`
add column `option_time` datetime default null after `create_time`,
add column `ingress_template` text collate utf8mb4_general_ci comment
'ingress模版文件',
add column `default_mode_ingress` text collate utf8mb4_general_ci comment
'配置ingress的域名',
- add column `modify_time` datetime not null default current_timestamp on
update current_timestamp after `create_time`,
+ add column `modify_time` datetime default null after `create_time`,
add column `tags` varchar(500) default null;
alter table `t_flink_log` add column `job_manager_url` varchar(255) default
null after `yarn_app_id`;
@@ -78,7 +78,7 @@ alter table `t_flink_project`
add column `team_id` bigint not null comment 'team id' default 100000
after `id`,
add column `git_credential` tinyint not null default 1 after `id`,
add column `prvkey_path` varchar(255) collate utf8mb4_general_ci default
null after `password`,
- add column `modify_time` datetime not null default current_timestamp on
update current_timestamp after `create_time`,
+ add column `modify_time` datetime default null after `create_time`,
add index `inx_team` (`team_id`) using btree;
update `t_flink_project` set git_credential=1 where url like 'http%';
@@ -89,7 +89,7 @@ alter table `t_flink_cluster`
change column `dynamic_options` `dynamic_properties` text comment 'allows
specifying multiple generic configuration options';
-- 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;
+alter table `t_app_build_pipe` change column `update_time` `modify_time`
datetime default null on update current_timestamp;
-- change `readed` to `is_read`
@@ -119,10 +119,10 @@ alter table `t_user` modify `create_time` datetime not
null default current_time
alter table `t_flink_cluster` modify `create_time` datetime not null default
current_timestamp;
alter table `t_access_token` modify `create_time` datetime not null default
current_timestamp;
-alter table `t_access_token` modify `modify_time` datetime not null default
current_timestamp on update current_timestamp;
-alter table `t_menu` modify `modify_time` datetime not null default
current_timestamp on update current_timestamp;
-alter table `t_role` modify `modify_time` datetime not null default
current_timestamp on update current_timestamp;
-alter table `t_user` modify `modify_time` datetime not null default
current_timestamp on update current_timestamp;
+alter table `t_access_token` modify `modify_time` datetime default null on
update current_timestamp;
+alter table `t_menu` modify `modify_time` datetime default null on update
current_timestamp;
+alter table `t_role` modify `modify_time` datetime default null on update
current_timestamp;
+alter table `t_user` modify `modify_time` datetime default null on update
current_timestamp;
-- add new modules to the menu
delete from `t_menu`;
@@ -262,8 +262,8 @@ create table `t_team` (
`id` bigint not null auto_increment comment 'team id',
`team_name` varchar(50) collate utf8mb4_general_ci not null comment 'team
name',
`description` varchar(255) collate utf8mb4_general_ci default null,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `team_name_idx` (`team_name`) using btree
) engine = innodb default charset = utf8mb4 collate = utf8mb4_general_ci;
@@ -297,8 +297,8 @@ alter table `t_member`
add column `team_id` bigint not null comment 'team id' default 100000 after
`id`,
modify column `user_id` bigint not null comment 'user id',
modify column `role_id` bigint not null comment 'role id',
-add column `create_time` datetime not null default current_timestamp comment
'create time',
-add column `modify_time` datetime not null default current_timestamp on
update current_timestamp comment 'modify time',
+add column `create_time` datetime default null comment 'create time',
+add column `modify_time` datetime default null comment 'modify time',
drop index `UN_INX`,
add unique key `un_user_team_role_inx` (`user_id`,`team_id`,`role_id`) using
btree;
@@ -316,9 +316,9 @@ change column `DESCRIPTION` `description` varchar(255)
collate utf8mb4_general_c
change column `TYPE` `type` tinyint not null comment '1: input 2: boolean 3:
number',
add primary key (`setting_key`);
-insert into `t_setting` values (14, 'docker.register.namespace', null, 'Docker
Register Image namespace', 'Docker命名空间', 1);
-insert into `t_setting` values (15, 'streampark.maven.settings', null, 'Maven
Settings File Path', 'Maven Settings.xml 完整路径', 1);
-insert into `t_setting` values (16, 'ingress.mode.default', null,
'Automatically generate an nginx-based ingress by passing in a domain name',
'Ingress域名地址', 1);
+insert into `t_setting` values (14, 'docker.register.namespace', null, 'Docker
namespace', 'Namespace for docker image used in docker building env and target
image register', 1);
+insert into `t_setting` values (15, 'streampark.maven.settings', null, 'Maven
Settings File Path', 'Maven Settings.xml full path', 1);
+insert into `t_setting` values (16, 'ingress.mode.default', null, 'Ingress
domain address', 'Automatically generate an nginx-based ingress by passing in a
domain name', 1);
update t_setting set setting_key = replace(setting_key, 'streamx',
'streampark') where setting_key like 'streamx%';
@@ -339,8 +339,8 @@ create table `t_variable` (
`creator_id` bigint collate utf8mb4_general_ci not null comment 'user id of
creator',
`team_id` bigint collate utf8mb4_general_ci not null comment 'team id',
`desensitization` tinyint not null default 0 comment '0 is no
desensitization, 1 is desensitization, if set to desensitization, it will be
replaced by * when displayed',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `un_team_vcode_inx` (`team_id`,`variable_code`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
index 042b09a53..e09ce96ba 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
@@ -27,8 +27,8 @@ CREATE TABLE `t_external_link` (
`badge_name` varchar(64) collate utf8mb4_general_ci default null,
`badge_color` varchar(64) collate utf8mb4_general_ci default null,
`link_url` varchar(255) collate utf8mb4_general_ci default null,
- `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'
+ `create_time` datetime default null COMMENT 'create time',
+ `modify_time` datetime default null COMMENT 'modify time'
) engine = innodb default charset=utf8mb4 collate=utf8mb4_general_ci;
drop table if exists `t_yarn_queue`;
@@ -37,8 +37,8 @@ create table `t_yarn_queue` (
`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(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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null 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;
@@ -121,6 +121,7 @@ alter table `t_flink_cluster`
alter table `t_access_token`
modify column `description` varchar(255) character set utf8mb4 collate
utf8mb4_general_ci default null comment 'description';
+
-- menu script
delete from `t_menu`;
-- menu level 1
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
index c35c13c8f..355f1b0de 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
@@ -34,8 +34,8 @@ create table `t_resource` (
`description` text collate utf8mb4_general_ci default null comment 'More
detailed description of resource',
`creator_id` bigint collate utf8mb4_general_ci not null comment 'user id of
creator',
`team_id` bigint collate utf8mb4_general_ci not null comment 'team id',
-`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',
+`create_time` datetime default null comment 'create time',
+`modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree,
unique key `un_team_vcode_inx` (`team_id`,`resource_name`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
@@ -87,8 +87,8 @@ create table `t_flink_gateway` (
`description` text collate utf8mb4_general_ci default null comment 'More
detailed description of resource',
`gateway_type` int not null comment 'The type of the gateway',
`address` varchar(150) default null comment 'url address of gateway endpoint',
-`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',
+`create_time` datetime default null comment 'create time',
+`modify_time` datetime default null comment 'modify time',
primary key (`id`) using btree
) engine=innodb auto_increment=100000 default charset=utf8mb4
collate=utf8mb4_general_ci;
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql
index bb7e5d1c2..f8f193fbc 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql
@@ -25,8 +25,8 @@ create table "public"."t_external_link" (
"badge_name" varchar(100) collate "pg_catalog"."default",
"badge_color" varchar(100) collate "pg_catalog"."default",
"link_url" varchar(1000) collate "pg_catalog"."default",
-"create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
-"modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+"create_time" timestamp(6),
+"modify_time" timestamp(6)
);
alter table "public"."t_external_link" add constraint "t_external_link_pkey"
primary key ("id");
@@ -40,8 +40,8 @@ create table "public"."t_yarn_queue" (
"team_id" int8 not null,
"queue_label" varchar(128) not null collate "pg_catalog"."default",
"description" varchar(256) collate "pg_catalog"."default",
-"create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
-"modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+"create_time" timestamp(6),
+"modify_time" timestamp(6)
);
comment on column "public"."t_yarn_queue"."id" is 'queue id';
comment on column "public"."t_yarn_queue"."team_id" is 'team id';
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
index 8e78a37cb..a2add60cf 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
@@ -34,8 +34,8 @@ create table "public"."t_resource" (
"connector_required_options" text default null,
"connector_optional_options" text default null,
"team_id" int8 not null,
-"create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
-"modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+"create_time" timestamp(6),
+"modify_time" timestamp(6)
);
comment on column "public"."t_resource"."id" is 'Resource id';
@@ -99,8 +99,8 @@ create table "public"."t_flink_gateway" (
"description" text collate "pg_catalog"."default" default null,
"gateway_type" int4,
"address" varchar(150) collate "pg_catalog"."default",
-"create_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone),
-"modify_time" timestamp(6) not null default timezone('UTC-8'::text,
(now())::timestamp(0) without time zone)
+"create_time" timestamp(6),
+"modify_time" timestamp(6)
);
comment on column "public"."t_flink_gateway"."id" is 'The id of the gateway';
comment on column "public"."t_flink_gateway"."gateway_name" is 'The name of
the gateway';
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java
index 5fb9cd14d..82f463696 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java
@@ -62,13 +62,6 @@ public class SettingController {
return RestResponse.success(setting);
}
- @Operation(summary = "Get streampark address")
- @PostMapping("weburl")
- public RestResponse webUrl() {
- String url = settingService.getStreamParkAddress();
- return RestResponse.success(url == null ? null : url.trim());
- }
-
@Operation(summary = "Update setting")
@PostMapping("update")
@RequiresPermissions("setting:update")
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
index 9b415af59..67637440b 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
@@ -103,7 +103,7 @@ public class FlinkCluster implements Serializable {
private Integer clusterState;
- private Date createTime = new Date();
+ private Date createTime;
private Date startTime;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
index 6053ca717..e30960ca0 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
@@ -75,9 +75,9 @@ public class Resource implements Serializable {
@NotNull(message = "{required}")
private Long teamId;
- private transient Date createTime;
+ private Date createTime;
- private transient Date modifyTime;
+ private Date modifyTime;
private transient String connector;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
index 35e7789a4..f289ab8a0 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
@@ -60,9 +60,9 @@ public class Variable implements Serializable {
private Boolean desensitization;
- private transient Date createTime;
+ private Date createTime;
- private transient Date modifyTime;
+ private Date modifyTime;
public void dataMasking() {
if (desensitization) {
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
index e96a54b5b..102e0730d 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
@@ -323,8 +323,9 @@ public class ApplicationManageServiceImpl extends
ServiceImpl<ApplicationMapper,
appParam.setState(FlinkAppStateEnum.ADDED.getValue());
appParam.setRelease(ReleaseStateEnum.NEED_RELEASE.get());
appParam.setOptionState(OptionStateEnum.NONE.getValue());
- appParam.setCreateTime(new Date());
- appParam.setModifyTime(appParam.getCreateTime());
+ Date date = new Date();
+ appParam.setCreateTime(date);
+ appParam.setModifyTime(date);
appParam.setDefaultModeIngress(settingService.getIngressModeDefault());
boolean success = validateQueueIfNeeded(appParam);
@@ -432,8 +433,9 @@ public class ApplicationManageServiceImpl extends
ServiceImpl<ApplicationMapper,
newApp.setState(FlinkAppStateEnum.ADDED.getValue());
newApp.setRelease(ReleaseStateEnum.NEED_RELEASE.get());
newApp.setOptionState(OptionStateEnum.NONE.getValue());
- newApp.setCreateTime(new Date());
- newApp.setModifyTime(new Date());
+ Date date = new Date();
+ newApp.setCreateTime(date);
+ newApp.setModifyTime(date);
newApp.setHotParams(oldApp.getHotParams());
newApp.setJar(oldApp.getJar());
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
index 1cc365c0a..1a88494e4 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
@@ -53,8 +53,9 @@ public class ExternalLinkServiceImpl extends
ServiceImpl<ExternalLinkMapper, Ext
if (!this.check(externalLink)) {
return;
}
- externalLink.setCreateTime(new Date());
- externalLink.setModifyTime(new Date());
+ Date date = new Date();
+ externalLink.setCreateTime(date);
+ externalLink.setModifyTime(date);
externalLink.setId(null);
this.save(externalLink);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
index fe8ec4902..092a70d74 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
@@ -95,7 +95,9 @@ public class ProjectServiceImpl extends
ServiceImpl<ProjectMapper, Project>
ApiAlertException.throwIfTrue(count > 0, "project name already exists, add
project failed");
- project.setCreateTime(new Date());
+ Date date = new Date();
+ project.setCreateTime(date);
+ project.setModifyTime(date);
boolean status = save(project);
if (status) {
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
index c72dc9e79..44e1eb9dc 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
@@ -109,7 +109,9 @@ public class AuthenticatorImpl implements Authenticator {
private User newUserCreate(LoginTypeEnum loginTypeEnum, String username)
throws Exception {
User newUser = new User();
- newUser.setCreateTime(new Date());
+ Date date = new Date();
+ newUser.setCreateTime(date);
+ newUser.setModifyTime(date);
newUser.setUsername(username);
newUser.setNickName(username);
newUser.setLoginType(loginTypeEnum);
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
index b87656fc5..3b982281e 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
@@ -74,7 +74,9 @@ public class AccessTokenServiceImpl extends
ServiceImpl<AccessTokenMapper, Acces
accessToken.setUserId(user.getUserId());
accessToken.setDescription(description);
accessToken.setExpireTime(DateUtils.stringToDate(jwtToken.getExpireAt()));
- accessToken.setCreateTime(new Date());
+ Date date = new Date();
+ accessToken.setCreateTime(date);
+ accessToken.setModifyTime(date);
accessToken.setStatus(AccessToken.STATUS_ENABLE);
this.save(accessToken);
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
index 4c231a63a..90f7975b9 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
@@ -144,8 +144,10 @@ public class MemberServiceImpl extends
ServiceImpl<MemberMapper, Member> impleme
member.setId(null);
member.setUserId(user.getUserId());
- member.setCreateTime(new Date());
- member.setModifyTime(team.getCreateTime());
+
+ Date date = new Date();
+ member.setCreateTime(date);
+ member.setModifyTime(date);
this.save(member);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
index 66c100142..ed272fbc3 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
@@ -72,7 +72,9 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper,
Role> implements Ro
@Override
public void createRole(Role role) {
- role.setCreateTime(new Date());
+ Date date = new Date();
+ role.setCreateTime(date);
+ role.setModifyTime(date);
this.save(role);
String[] menuIds = role.getMenuId().split(StringPool.COMMA);
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
index 263eb162c..d7079a345 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
@@ -85,8 +85,9 @@ public class TeamServiceImpl extends ServiceImpl<TeamMapper,
Team> implements Te
"Team name [%s] exists already. Create team failed. Please rename
and try again.",
team.getTeamName()));
team.setId(null);
- team.setCreateTime(new Date());
- team.setModifyTime(team.getCreateTime());
+ Date date = new Date();
+ team.setCreateTime(date);
+ team.setModifyTime(date);
this.save(team);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
index c638d16e4..1ae53feaa 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
@@ -111,7 +111,9 @@ public class UserServiceImpl extends
ServiceImpl<UserMapper, User> implements Us
@Override
public void createUser(User user) {
- user.setCreateTime(new Date());
+ Date date = new Date();
+ user.setCreateTime(date);
+ user.setModifyTime(date);
if (StringUtils.isNoneBlank(user.getPassword())) {
String salt = ShaHashUtils.getRandomSalt();
String password = ShaHashUtils.encrypt(salt, user.getPassword());
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 8ddbda807..c666f50cf 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
@@ -26,8 +26,8 @@ create table if not exists `t_app_backup` (
`version` int default null,
`path` varchar(128) default null,
`description` varchar(255) default null,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`id`)
);
@@ -79,8 +79,8 @@ create table if not exists `t_flink_app` (
`available_slot` int default null,
`option_state` tinyint default null,
`tracking` tinyint default null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
- `modify_time` datetime not null default current_timestamp comment 'modify
time',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
`option_time` datetime default null,
`release` tinyint default 1,
`build` tinyint default 1,
@@ -110,7 +110,7 @@ create table if not exists `t_flink_config` (
`version` int not null,
`latest` tinyint not null default 0,
`content` text not null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key(`id`)
);
@@ -122,7 +122,7 @@ create table if not exists `t_flink_effective` (
`app_id` bigint not null,
`target_type` tinyint not null comment '1) config 2) flink sql',
`target_id` bigint not null comment 'configId or sqlId',
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key(`id`),
unique (`app_id`,`target_type`)
);
@@ -139,7 +139,7 @@ create table if not exists `t_flink_env` (
`flink_conf` text not null comment 'flink-conf',
`is_default` tinyint not null default 0 comment 'whether default version or
not',
`description` varchar(255) default null comment 'description',
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key(`id`),
unique (`flink_name`)
);
@@ -180,8 +180,8 @@ create table if not exists `t_flink_project` (
`last_build` datetime default null,
`description` varchar(255) default null,
`build_state` tinyint default -1,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`id`)
);
@@ -197,7 +197,7 @@ create table if not exists `t_flink_savepoint` (
`path` varchar(255) default null,
`latest` tinyint not null default 1,
`trigger_time` datetime default null,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key(`id`)
);
@@ -212,7 +212,7 @@ create table if not exists `t_flink_sql` (
`dependency` text ,
`version` int default null,
`candidate` tinyint not null default 1,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key(`id`)
);
@@ -232,8 +232,8 @@ create table if not exists `t_resource` (
`connector_required_options` text default null,
`connector_optional_options` text default null,
`team_id` bigint not null comment 'team id',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`)
);
@@ -251,8 +251,8 @@ create table if not exists `t_menu` (
`type` char(2) default null comment 'type 0:menu 1:button',
`display` tinyint not null default 0 comment 'whether the menu is displayed',
`order_num` int default null comment 'sort',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`menu_id`)
);
@@ -267,7 +267,7 @@ create table if not exists `t_message` (
`title` varchar(255) default null,
`context` text ,
`is_read` tinyint default 0,
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
primary key(`id`)
);
@@ -278,8 +278,8 @@ create table if not exists `t_team` (
`id` bigint generated by default as identity not null comment 'team id',
`team_name` varchar(64) not null comment 'team name',
`description` varchar(255) default null,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`),
unique (`team_name`)
);
@@ -295,8 +295,8 @@ create table if not exists `t_variable` (
`creator_id` bigint not null comment 'user id of creator',
`team_id` bigint not null comment 'team id',
`desensitization` tinyint not null default 0 comment '0 is no
desensitization, 1 is desensitization, if set to desensitization, it will be
replaced by * when displayed',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key (`id`),
unique (`team_id`, `variable_code`)
);
@@ -307,8 +307,8 @@ create table if not exists `t_variable` (
create table if not exists `t_role` (
`role_id` bigint generated by default as identity not null comment 'user id',
`role_name` varchar(64) not null comment 'user name',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
`description` varchar(255) default null comment 'description',
primary key(`role_id`)
);
@@ -350,8 +350,8 @@ create table if not exists `t_user` (
`login_type` tinyint default 0 comment 'login type 0:password 1:ldap 2:sso',
`last_team_id` bigint default null comment 'last team id',
`status` char(1) not null comment 'status 0:locked 1:active',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
`last_login_time` datetime default null comment 'last login time',
`sex` char(1) default null comment 'gender 0:male 1:female 2:confidential',
`avatar` varchar(128) default null comment 'avatar',
@@ -368,8 +368,8 @@ create table if not exists `t_member` (
`team_id` bigint not null comment 'team id',
`user_id` bigint not null comment 'user id',
`role_id` bigint not null comment 'role id',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`id`),
unique (`team_id`, `user_id`,`role_id`)
);
@@ -387,7 +387,7 @@ create table if not exists `t_app_build_pipe` (
`steps_status_ts` text,
`error` text,
`build_result` text,
- `modify_time` datetime not null default current_timestamp on update
current_timestamp comment 'modify time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`app_id`)
);
@@ -416,7 +416,7 @@ create table if not exists `t_flink_cluster` (
`resolve_order` tinyint default null,
`exception` text comment 'exception information',
`cluster_state` tinyint default 0 comment 'cluster status (0: created but
not started, 1: started, 2: stopped)',
- `create_time` datetime not null default current_timestamp comment 'create
time',
+ `create_time` datetime default null comment 'create time',
`start_time` datetime default null comment 'start time',
`end_time` datetime default null comment 'end time',
`alert_id` bigint default null comment 'alert id',
@@ -438,8 +438,8 @@ create table if not exists `t_alert_config` (
`we_com_params` varchar(255) comment 'wechat params',
`http_callback_params` text comment 'http callback params',
`lark_params` text comment 'lark params',
- `create_time` datetime not null default current_timestamp comment 'create
time',
- `modify_time` datetime not null default current_timestamp on update
current_timestamp comment 'change time',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime not null default current_timestamp comment 'change
time',
primary key(`id`)
);
@@ -454,8 +454,8 @@ create table if not exists `t_access_token` (
`expire_time` datetime default null comment 'expiration',
`description` varchar(255) default null comment 'description',
`status` tinyint default null comment '1:enable,0:disable',
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`id`)
);
@@ -469,8 +469,8 @@ create table if not exists `t_external_link` (
`badge_name` varchar(64) default null,
`badge_color` varchar(64) default null,
`link_url` varchar(255) default null,
- `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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
primary key(`id`)
);
@@ -484,8 +484,8 @@ create table if not exists `t_yarn_queue` (
`team_id` bigint not null comment 'team id',
`queue_label` varchar(128) not null comment 'queue label expression',
`description` varchar(255) 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',
+ `create_time` datetime default null comment 'create time',
+ `modify_time` datetime default null comment 'modify time',
unique key (`team_id`,`queue_label`),
primary key (`id`)
);
