GAL-585 增加分布式表distributed_ddl_queue_cluster

This commit is contained in:
wangkuan
2024-06-05 16:28:27 +08:00
parent 30ed8f7315
commit a67b6026b9
2 changed files with 4 additions and 1 deletions

View File

@@ -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`.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()); 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; 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());

View File

@@ -1090,3 +1090,5 @@ ENGINE = Distributed('ck_cluster',
'tsg_galaxy_v3', 'tsg_galaxy_v3',
'traffic_sketch_metric_local', 'traffic_sketch_metric_local',
rand()); 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());