diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
index b2065a39c1..9e929c22de 100644
--- a/flow/connectors/snowflake/snowflake.go
+++ b/flow/connectors/snowflake/snowflake.go
@@ -742,7 +742,7 @@ func (c *SnowflakeConnector) NormalizeRecords(req *model.NormalizeRecordsRequest
 
 	var totalRowsAffected int64 = 0
 	g, gCtx := errgroup.WithContext(c.ctx)
-	g.SetLimit(8) // limit parallel merges to 8
+	g.SetLimit(32) // limit parallel merges to 32
 
 	for _, destinationTableName := range destinationTableNames {
 		tableName := destinationTableName // local variable for the closure