feat: remove 'on cluster' while alert table

erda-project · Feb 26, 2025 · 5c80105 · 5c80105
1 parent 045f549
commit 5c80105
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/tools/monitor/core/storekit/clickhouse/table/initializer/ttl_sync.go b/internal/tools/monitor/core/storekit/clickhouse/table/initializer/ttl_sync.go
@@ -94,11 +94,11 @@ func (p *provider) needTTLUpdate(ttl *retention.TTL, meta *loader.TableMeta) boo
 }
 
 func (p *provider) AlterTableTTL(tableName string, meta *loader.TableMeta, ttl *retention.TTL) {
-	sql := "ALTER TABLE <table> ON CLUSTER '{cluster}' MODIFY TTL <time_key> + INTERVAL <ddl_days> DAY;"
+	sql := "ALTER TABLE <table> MODIFY TTL <time_key> + INTERVAL <ddl_days> DAY;"
 	ttlHotDays, ttlDays := ttl.GetHotTTLByDays(), ttl.GetTTLByDays()
 
 	if p.Cfg.ColdHotEnable && ttlHotDays > 0 && ttlDays > ttlHotDays {
-		sql = "ALTER TABLE <table> ON CLUSTER '{cluster}' MODIFY TTL <time_key> + toIntervalDay(<hot_ddl_days>) TO VOLUME 'slow', <time_key> + toIntervalDay(<ddl_days>);"
+		sql = "ALTER TABLE <table> MODIFY TTL <time_key> + toIntervalDay(<hot_ddl_days>) TO VOLUME 'slow', <time_key> + toIntervalDay(<ddl_days>);"
 	}
 	if len(meta.TimeKey) <= 0 {
 		p.Log.Warnf("failed exec ttl, not time key!!", tableName)