We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ec8a677 commit e28005bCopy full SHA for e28005b
flow/connectors/clickhouse/normalize.go
@@ -100,7 +100,7 @@ func (c *ClickHouseConnector) generateCreateTableSQLForNormalizedTable(
100
case protos.TableEngine_CH_ENGINE_REPLACING_MERGE_TREE, protos.TableEngine_CH_ENGINE_REPLICATED_REPLACING_MERGE_TREE:
101
if c.config.Replicated {
102
engine = fmt.Sprintf(
103
- "ReplicatedReplacingMergeTree(%s%s','{replica}',%s)",
+ "ReplicatedReplacingMergeTree('%s%s','{replica}',%s)",
104
zooPathPrefix,
105
peerdb_clickhouse.EscapeStr(tableIdentifier),
106
peerdb_clickhouse.QuoteIdentifier(versionColName),
0 commit comments