From a67b6026b9adf137169dcc794151e9f1420b731d Mon Sep 17 00:00:00 2001 From: wangkuan Date: Wed, 5 Jun 2024 16:28:27 +0800 Subject: [PATCH] =?UTF-8?q?GAL-585=20=E5=A2=9E=E5=8A=A0=E5=88=86=E5=B8=83?= =?UTF-8?q?=E5=BC=8F=E8=A1=A8distributed=5Fddl=5Fqueue=5Fcluster?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tsg_olap/installation/clickhouse/最新全量建表语句/system.sql | 1 + .../clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.06.sql | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/tsg_olap/installation/clickhouse/最新全量建表语句/system.sql b/tsg_olap/installation/clickhouse/最新全量建表语句/system.sql index 3ee0198..6bc7150 100644 --- a/tsg_olap/installation/clickhouse/最新全量建表语句/system.sql +++ b/tsg_olap/installation/clickhouse/最新全量建表语句/system.sql @@ -5,4 +5,5 @@ create table IF NOT EXISTS `system`.query_log_cluster ON CLUSTER ck_cluster as ` CREATE TABLE IF NOT EXISTS `system`.columns_cluster ON CLUSTER ck_cluster AS `system`.columns ENGINE=Distributed(ck_cluster,`system`,columns,rand()); CREATE TABLE IF NOT EXISTS `system`.processes_cluster ON CLUSTER ck_cluster AS `system`.processes ENGINE=Distributed(ck_cluster,`system`,processes,rand()); alter table system.query_log on cluster ck_cluster modify TTL event_date + INTERVAL 60 DAY; +create table IF not EXISTS system.distributed_ddl_queue_cluster ON CLUSTER ck_cluster as system.distributed_ddl_queue ENGINE =Distributed(ck_cluster,`system`,distributed_ddl_queue,rand()); diff --git a/tsg_olap/upgrade/TSG-24.06/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.06.sql b/tsg_olap/upgrade/TSG-24.06/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.06.sql index 70bd3bf..275ffa9 100644 --- a/tsg_olap/upgrade/TSG-24.06/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.06.sql +++ b/tsg_olap/upgrade/TSG-24.06/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.06.sql @@ -1089,4 +1089,6 @@ ORDER BY (vsys_id, ENGINE = Distributed('ck_cluster', 'tsg_galaxy_v3', 'traffic_sketch_metric_local', - rand()); \ No newline at end of file + rand()); + +create table IF not EXISTS system.distributed_ddl_queue_cluster ON CLUSTER ck_cluster as system.distributed_ddl_queue ENGINE =Distributed(ck_cluster,`system`,distributed_ddl_queue,rand());