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
PeerDB-io · Feb 12, 2024 · 29b65d4 · 29b65d4
1 parent 9c17dff
commit 29b65d4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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