Skip to content

Commit cef57e2

Browse files
committed
don't use {table} to avoid issues renaming (such as in resync)
1 parent 7f7a660 commit cef57e2

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

flow/connectors/clickhouse/normalize.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -170,12 +170,14 @@ func generateCreateTableSQLForNormalizedTable(
170170
engine = "MergeTree()"
171171
case protos.TableEngine_CH_ENGINE_REPLICATED_REPLACING_MERGE_TREE:
172172
engine = fmt.Sprintf(
173-
"ReplicatedReplacingMergeTree('/clickhouse/tables/{shard}/{database}/{table}','{replica}',%s)",
173+
"ReplicatedReplacingMergeTree('/clickhouse/tables/{shard}/{database}/%s','{replica}',%s)",
174+
peerdb_clickhouse.EscapeStr(tableIdentifier),
174175
peerdb_clickhouse.QuoteIdentifier(versionColName),
175176
)
176177
case protos.TableEngine_CH_ENGINE_REPLICATED_MERGE_TREE:
177178
engine = fmt.Sprintf(
178-
"ReplicatedMergeTree('/clickhouse/tables/{shard}/{database}/{table}','{replica}',%s)",
179+
"ReplicatedMergeTree('/clickhouse/tables/{shard}/{database}/%s','{replica}',%s)",
180+
peerdb_clickhouse.EscapeStr(tableIdentifier),
179181
peerdb_clickhouse.QuoteIdentifier(versionColName),
180182
)
181183
case protos.TableEngine_CH_ENGINE_NULL:

0 commit comments

Comments
 (0)