From 98bba14e7540954617b76191dab1acc75c87323e Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Wed, 15 Nov 2023 14:44:54 -0500
Subject: [PATCH] commit the tx

---
 flow/connectors/snowflake/snowflake.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
index ace3cc2ca3..e73331be0f 100644
--- a/flow/connectors/snowflake/snowflake.go
+++ b/flow/connectors/snowflake/snowflake.go
@@ -1111,6 +1111,11 @@ func (c *SnowflakeConnector) generateAndExecuteMergeStatement(
 			destinationTableIdentifier, mergeStatement, err)
 	}
 
+	err = mergeTx.Commit()
+	if err != nil {
+		return 0, fmt.Errorf("unable to commit transaction for merge: %w", err)
+	}
+
 	endTime := time.Now()
 	log.Infof("[merge] merged records into %s, took: %d seconds",
 		destinationTableIdentifier, endTime.Sub(startTime)/time.Second)