fix: set alter_sync = 0 when add columns on cluster

housepower · Apr 2, 2024 · fd3c332 · fd3c332
1 parent 63d97f4
commit fd3c332
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/output/clickhouse.go b/output/clickhouse.go
@@ -581,7 +581,7 @@ func (c *ClickHouse) ChangeSchema(newKeys *sync.Map) (err error) {
 	}
 
 	alterTable := func(tbl, col string) error {
-		query := fmt.Sprintf("ALTER TABLE `%s`.`%s` %s %s;", c.dbName, tbl, onCluster, col)
+		query := fmt.Sprintf("ALTER TABLE `%s`.`%s` %s %s SETTINGS alter_sync = 0;", c.dbName, tbl, onCluster, col)
 		util.Logger.Info(fmt.Sprintf("executing sql=> %s", query), zap.String("task", taskCfg.Name))
 		return conn.Exec(query)
 	}