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 dd4997c94 fix t_flink_app Missing "hadoop_user" field (#3482)
dd4997c94 is described below
commit dd4997c947064c1b5330e4f4d6edb4385ea5a99c
Author: kkop <[email protected]>
AuthorDate: Thu Jan 11 08:56:02 2024 +0800
fix t_flink_app Missing "hadoop_user" field (#3482)
---
.../src/main/assembly/script/data/mysql-data.sql | 2 +-
.../src/main/assembly/script/data/pgsql-data.sql | 2 +-
.../src/main/assembly/script/schema/mysql-schema.sql | 1 +
.../src/main/assembly/script/schema/pgsql-schema.sql | 3 ++-
4 files changed, 5 insertions(+), 3 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
index 3650b01c3..be58d97a2 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
@@ -30,7 +30,7 @@ insert into `t_team` values (100000, 'default', null, now(),
now());
-- ----------------------------
-- Records of t_flink_app
-- ----------------------------
-insert into `t_flink_app` values (100000, 100000, 2, 4, null, null, 'Flink SQL
Demo', null, null, null, null, null, null , null, 100000, null, 1, null, null,
null, null, null, null, null, null, 0, 0, null, null, null, null, null, null,
'Flink SQL Demo', 0, null, null, null, null, null, null, null, 0, 0, now(),
now(), null, 1, 1, null, null, null, null, null, null, 0, null, null, null,
'streampark,test', 0);
+insert into `t_flink_app` values (100000, 100000, 2, 4, null, null, 'Flink SQL
Demo', null, null, null, null, null, null , null, 100000, null, 1, null, null,
null, null, null, null, null, null, 0, 0, null, null, null, null, null, null,
'Flink SQL Demo', 0, null, null, null, null, null, null, null, 0, 0, now(),
now(), null, 1, 1, null, null, null, null, null, null, 0, null, null, null,
'streampark,test', 0, null);
-- ----------------------------
-- Records of t_flink_effective
diff --git
a/streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
b/streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
index 1b2b72657..1e9246a88 100644
---
a/streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
+++
b/streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
@@ -25,7 +25,7 @@ insert into "public"."t_team" values (100000, 'default',
null, now(), now());
-- ----------------------------
-- Records of t_flink_app
-- ----------------------------
-insert into "public"."t_flink_app" values (100000, 100000, 2, 4, null, null,
'Flink SQL Demo', null, null, null, null, null, null , null, 100000, null, 1,
null, null, null, null, null, null, null, null, 0, 0, null, null, null, null,
null, null, 'Flink SQL Demo', 0, null, null, null, null, null, null, null, 0,
0, now(), now(), null, 1, true, null, null, null, null, null, null, false,
null, null, null, 'streampark,test', false);
+insert into "public"."t_flink_app" values (100000, 100000, 2, 4, null, null,
'Flink SQL Demo', null, null, null, null, null, null , null, 100000, null, 1,
null, null, null, null, null, null, null, null, 0, 0, null, null, null, null,
null, null, 'Flink SQL Demo', 0, null, null, null, null, null, null, null, 0,
0, now(), now(), null, 1, true, null, null, null, null, null, null, false,
null, null, null, 'streampark,test', false, null);
-- ----------------------------
-- Records of t_flink_effective
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 3a00c9b8c..a067c2e46 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
@@ -103,6 +103,7 @@ create table `t_flink_app` (
`default_mode_ingress` text collate utf8mb4_general_ci,
`tags` varchar(500) default null,
`probing` tinyint default 0,
+ `hadoop_user` varchar(64) collate utf8mb4_general_ci default null,
primary key (`id`) using btree,
key `inx_job_type` (`job_type`) using btree,
key `inx_track` (`tracking`) using btree,
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 02cd0cfcd..b0888bbe6 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
@@ -250,7 +250,8 @@ create table "public"."t_flink_app" (
"ingress_template" text collate "pg_catalog"."default",
"default_mode_ingress" text collate "pg_catalog"."default",
"tags" varchar(500) collate "pg_catalog"."default",
- "probing" boolean default false
+ "probing" boolean default false,
+ "hadoop_user" varchar(63) collate "pg_catalog"."default"
)
;
alter table "public"."t_flink_app" add constraint "t_flink_app_pkey" primary
key ("id");
