diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index f3b6852623..ab0bab2ca6 100644 --- a/flow/connectors/snowflake/snowflake.go +++ b/flow/connectors/snowflake/snowflake.go @@ -1019,7 +1019,8 @@ func (c *SnowflakeConnector) generateAndExecuteMergeStatement( } insertValuesSQL := strings.TrimSuffix(strings.Join(insertValuesSQLArray, ""), ",") - updateStatementsforToastCols := c.generateUpdateStatement(normalizeReq.SyncedAtColName, columnNames, unchangedToastColumns) + updateStatementsforToastCols := c.generateUpdateStatement( + normalizeReq.SyncedAtColName, columnNames, unchangedToastColumns) updateStringToastCols := strings.Join(updateStatementsforToastCols, " ") pkeySelectSQLArray := make([]string, 0, len(normalizedTableSchema.PrimaryKeyColumns))