You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/09/14 14:41:06 UTC
[incubator-streampark] branch dev updated: add job_manager_url to h2sql for [improve] In the on yarn mode, when there are too many jobs, the number of ResourceManager connections is too high #1563 (#1605)
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 73a8c7b10 add job_manager_url to h2sql for [improve] In the on yarn mode, when there are too many jobs, the number of ResourceManager connections is too high #1563 (#1605)
73a8c7b10 is described below
commit 73a8c7b107616a9ca9b4af65c4dc5881e932e21d
Author: macksonmu <30...@qq.com>
AuthorDate: Wed Sep 14 22:40:59 2022 +0800
add job_manager_url to h2sql for [improve] In the on yarn mode, when there are too many jobs, the number of ResourceManager connections is too high #1563 (#1605)
Co-authored-by: mucj7 <mu...@chinaunicom.cn>
---
.../streampark-console-service/src/main/resources/db/data-h2.sql | 2 +-
.../streampark-console-service/src/main/resources/db/schema-h2.sql | 2 ++
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql b/streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
index 5a98ca66f..01dfac2ab 100644
--- a/streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
+++ b/streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
@@ -18,7 +18,7 @@
-- ----------------------------
-- Records of t_flink_app
-- ----------------------------
-insert into `t_flink_app` values (100000, 2, 4, null, null, 'Flink SQL Demo', null, null, null, null, null, null , null, 100000, null, 1, null, null, null, null, null, null, '0', 0, null, null, null, null, null, null, 'Flink SQL Demo', 0, null, 0, 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');
+insert into `t_flink_app` values (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, '0', 0, null, null, null, null, null, null, 'Flink SQL Demo', 0, null, 0, 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');
-- ----------------------------
-- Records of t_flink_effective
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 6ae114c41..61b82250d 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
@@ -64,6 +64,7 @@ create table if not exists `t_flink_app` (
`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,
@@ -158,6 +159,7 @@ create table if not exists `t_flink_log` (
`id` bigint generated by default as identity not null,
`app_id` bigint default null,
`yarn_app_id` varchar(50) default null,
+ `job_manager_url` varchar(255) default null,
`success` tinyint default null,
`exception` text ,
`option_time` datetime default null,