This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 52379ef541 [INLONG-9250][Manager] Add auditId for tube, pulsar, and
mysql (#9251)
52379ef541 is described below
commit 52379ef541917a83404fe30a2a40ad3bb32110f8
Author: fuweng11 <[email protected]>
AuthorDate: Sat Nov 11 14:38:51 2023 +0800
[INLONG-9250][Manager] Add auditId for tube, pulsar, and mysql (#9251)
---
.../src/main/resources/h2/apache_inlong_manager.sql | 12 +++++++++---
inlong-manager/manager-web/sql/apache_inlong_manager.sql | 12 +++++++++---
inlong-manager/manager-web/sql/changes-1.10.0.sql | 7 +++++++
3 files changed, 25 insertions(+), 6 deletions(-)
diff --git
a/inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql
b/inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql
index 2e02f2cc80..d27d70d5a3 100644
---
a/inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql
+++
b/inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql
@@ -826,8 +826,8 @@ VALUES ('audit_sdk_collect', 'SDK', 0, '1'),
('audit_sort_hive_output', 'HIVE', 1, '8'),
('audit_sort_clickhouse_input', 'CLICKHOUSE', 0, '9'),
('audit_sort_clickhouse_output', 'CLICKHOUSE', 1, '10'),
- ('audit_sort_es_input', 'ELASTICSEARCH', 0, '11'),
- ('audit_sort_es_output', 'ELASTICSEARCH', 1, '12'),
+ ('audit_sort_es_input', 'ES', 0, '11'),
+ ('audit_sort_es_output', 'ES', 1, '12'),
('audit_sort_starrocks_input', 'STARROCKS', 0, '13'),
('audit_sort_starrocks_output', 'STARROCKS', 1, '14'),
('audit_sort_hudi_input', 'HUDI', 0, '15'),
@@ -843,7 +843,13 @@ VALUES ('audit_sdk_collect', 'SDK', 0, '1'),
('audit_sort_kudu_input', 'KUDU', 0, '25'),
('audit_sort_kudu_output', 'KUDU', 1, '26'),
('audit_sort_postgres_input', 'POSTGRESQL', 0, '27'),
- ('audit_sort_postgres_output', 'POSTGRESQL', 1, '28');
+ ('audit_sort_postgres_output', 'POSTGRESQL', 1, '28'),
+ ('audit_sort_mysql_binlog_input', 'MYSQL_BINLOG', 0, '29'),
+ ('audit_sort_mysql_binlog_output', 'MYSQL_BINLOG', 1, '30'),
+ ('audit_sort_pulsar_input', 'PULSAR', 0, '31'),
+ ('audit_sort_pulsar_output', 'PULSAR', 1, '32'),
+ ('audit_sort_tube_input', 'TUBEMQ', 0, '33'),
+ ('audit_sort_tube_output', 'TUBEMQ', 1, '34');
-- ----------------------------
-- Table structure for audit_source
diff --git a/inlong-manager/manager-web/sql/apache_inlong_manager.sql
b/inlong-manager/manager-web/sql/apache_inlong_manager.sql
index 1054722f2d..eb57c5898c 100644
--- a/inlong-manager/manager-web/sql/apache_inlong_manager.sql
+++ b/inlong-manager/manager-web/sql/apache_inlong_manager.sql
@@ -872,8 +872,8 @@ VALUES ('audit_sdk_collect', 'SDK', 0, '1'),
('audit_sort_hive_output', 'HIVE', 1, '8'),
('audit_sort_clickhouse_input', 'CLICKHOUSE', 0, '9'),
('audit_sort_clickhouse_output', 'CLICKHOUSE', 1, '10'),
- ('audit_sort_es_input', 'ELASTICSEARCH', 0, '11'),
- ('audit_sort_es_output', 'ELASTICSEARCH', 1, '12'),
+ ('audit_sort_es_input', 'ES', 0, '11'),
+ ('audit_sort_es_output', 'ES', 1, '12'),
('audit_sort_starrocks_input', 'STARROCKS', 0, '13'),
('audit_sort_starrocks_output', 'STARROCKS', 1, '14'),
('audit_sort_hudi_input', 'HUDI', 0, '15'),
@@ -889,7 +889,13 @@ VALUES ('audit_sdk_collect', 'SDK', 0, '1'),
('audit_sort_kudu_input', 'KUDU', 0, '25'),
('audit_sort_kudu_output', 'KUDU', 1, '26'),
('audit_sort_postgres_input', 'POSTGRESQL', 0, '27'),
- ('audit_sort_postgres_output', 'POSTGRESQL', 1, '28');
+ ('audit_sort_postgres_output', 'POSTGRESQL', 1, '28'),
+ ('audit_sort_mysql_binlog_input', 'MYSQL_BINLOG', 0, '29'),
+ ('audit_sort_mysql_binlog_output', 'MYSQL_BINLOG', 1, '30'),
+ ('audit_sort_pulsar_input', 'PULSAR', 0, '31'),
+ ('audit_sort_pulsar_output', 'PULSAR', 1, '32'),
+ ('audit_sort_tube_input', 'TUBEMQ', 0, '33'),
+ ('audit_sort_tube_output', 'TUBEMQ', 1, '34');
-- ----------------------------
-- Table structure for audit_source
diff --git a/inlong-manager/manager-web/sql/changes-1.10.0.sql
b/inlong-manager/manager-web/sql/changes-1.10.0.sql
index a9e906f81e..d67e24ee1c 100644
--- a/inlong-manager/manager-web/sql/changes-1.10.0.sql
+++ b/inlong-manager/manager-web/sql/changes-1.10.0.sql
@@ -28,5 +28,12 @@ ALTER TABLE `inlong_stream`
UPDATE inlong_group SET status = 130 where status = 150;
+INSERT INTO `audit_base`(`name`, `type`, `is_sent`, `audit_id`)
+VALUES ('audit_sort_mysql_binlog_input', 'MYSQL_BINLOG', 0, '29'),
+ ('audit_sort_mysql_binlog_output', 'MYSQL_BINLOG', 1, '30'),
+ ('audit_sort_pulsar_input', 'PULSAR', 0, '31'),
+ ('audit_sort_pulsar_output', 'PULSAR', 1, '32'),
+ ('audit_sort_tube_input', 'TUBEMQ', 0, '33'),
+ ('audit_sort_tube_output', 'TUBEMQ', 1, '34');
