diff --git a/internal/db/merge.go b/internal/db/merge.go
index 820be8b72d..1720960ccd 100644
--- a/internal/db/merge.go
+++ b/internal/db/merge.go
@@ -119,6 +119,8 @@ func (db *db) executeMerge(ctx context.Context, dagMerge events.DAGMerge) error
 				ctx = SetContextTxn(ctx, txn)
 				mp.txn = txn
 				mp.ls.SetReadStorage(txn.DAGstore().AsIPLDStorage())
+				// Reset the CRDTs to avoid reusing the old transaction.
+				mp.mCRDTs = make(map[string]merklecrdt.MerkleCRDT)
 				continue
 			}
 			return err