From dbb6292765f0b24209428af491af5850479b9cd7 Mon Sep 17 00:00:00 2001
From: Mahdi Dibaiee <mdibaiee@pm.me>
Date: Fri, 26 Jan 2024 17:07:56 +0000
Subject: [PATCH] materialize-snowflake: unset internal state for empty
 bindings

---
 materialize-snowflake/snowflake.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/materialize-snowflake/snowflake.go b/materialize-snowflake/snowflake.go
index 190bb12e65..0020dd6aba 100644
--- a/materialize-snowflake/snowflake.go
+++ b/materialize-snowflake/snowflake.go
@@ -568,6 +568,7 @@ func (d *transactor) Acknowledge(ctx context.Context) (*pf.ConnectorState, error
 	var checkpointClear = make(checkpoint)
 	for _, b := range d.bindings {
 		checkpointClear[b.target.StateKey] = nil
+		delete(d.cp, b.target.StateKey)
 	}
 	var checkpointJSON, err = json.Marshal(checkpointClear)
 	if err != nil {