From 1ec7d893273c057473c589717fee03d3a231fa78 Mon Sep 17 00:00:00 2001
From: Will Baker <wbaker@gmail.com>
Date: Wed, 19 Feb 2025 11:50:21 -0500
Subject: [PATCH] materialize-databricks: reset `needsMerge` flag after each
 transaction

The next transaction might not have any updates, so reset the `needsMerge` flag
to prevent merge queries from being run indefinitely after one merge query has
been run.
---
 materialize-databricks/driver.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/materialize-databricks/driver.go b/materialize-databricks/driver.go
index 7469ab89e7..703038218e 100644
--- a/materialize-databricks/driver.go
+++ b/materialize-databricks/driver.go
@@ -421,6 +421,7 @@ func (d *transactor) Store(it *m.StoreIterator) (_ m.StartCommitFunc, err error)
 			Queries:  queries,
 			ToDelete: fullPaths,
 		}
+		b.needsMerge = false // reset for next round
 	}
 
 	return func(ctx context.Context, runtimeCheckpoint *protocol.Checkpoint) (*pf.ConnectorState, m.OpFuture) {