diff --git a/internal/dal/repository/clickhouse.go b/internal/dal/repository/clickhouse.go index fa8b64c..6a3f249 100644 --- a/internal/dal/repository/clickhouse.go +++ b/internal/dal/repository/clickhouse.go @@ -157,11 +157,6 @@ func (c *Clickhouse) CreateMigrationHistoryTable(ctx context.Context) error { tableName = c.options.TableName engine = "ReplacingMergeTree(apply_time)" } - if !c.options.Replicated && len(c.options.ClusterName) > 0 { - tableName += " ON CLUSTER " + c.options.ClusterName - engine = "ReplicatedReplacingMergeTree('/clickhouse/tables/{shard}/" + - c.options.ClusterName + "_" + c.options.TableName + "', '{replica}', apply_time)" - } q = fmt.Sprintf( `