fix: rebalance: settings mutations_sync = 1

housepower · Mar 6, 2024 · d9a1311 · d9a1311
1 parent 67d28b9
commit d9a1311
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/service/clickhouse/rebalance.go b/service/clickhouse/rebalance.go
@@ -516,7 +516,7 @@ func (r *CKRebalance) MoveBackup() error {
 
 			var failedParts []string
 			for _, part := range parts {
-				query := fmt.Sprintf("ALTER TABLE `%s`.`%s` ATTACH PART '%s'", r.Database, r.TmpTable, part)
+				query := fmt.Sprintf("ALTER TABLE `%s`.`%s` ATTACH PART '%s' settings mutations_sync=1", r.Database, r.TmpTable, part)
 				log.Logger.Debugf("[%s]%s", host, query)
 				if err = conn.Exec(query); err != nil {
 					failedParts = append(failedParts, part)