From 29b65d4a9c3ec0aa72c525387768767c3a418bd8 Mon Sep 17 00:00:00 2001 From: Amogh Bharadwaj Date: Tue, 13 Feb 2024 01:30:59 +0530 Subject: [PATCH] Clickhouse: Remove quote from Normalize statement (#1258) We were running into a syntax error with the insert-into-select statement in normalize flow due to quoting. This PR removes that --- flow/connectors/clickhouse/normalize.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/clickhouse/normalize.go b/flow/connectors/clickhouse/normalize.go index d6e91b06ec..eb840b86b7 100644 --- a/flow/connectors/clickhouse/normalize.go +++ b/flow/connectors/clickhouse/normalize.go @@ -161,7 +161,7 @@ func (c *ClickhouseConnector) NormalizeRecords(ctx context.Context, req *model.N clickhouseType = "String" } - projection.WriteString(fmt.Sprintf("JSONExtract(_peerdb_data, '%s', '%s') AS '%s', ", cn, clickhouseType, cn)) + projection.WriteString(fmt.Sprintf("JSONExtract(_peerdb_data, '%s', '%s') AS %s, ", cn, clickhouseType, cn)) } // add _peerdb_sign as _peerdb_record_type / 2