diff --git a/flow/connectors/utils/cdc_store.go b/flow/connectors/utils/cdc_store.go index e3aa9e449..d3e9d27f8 100644 --- a/flow/connectors/utils/cdc_store.go +++ b/flow/connectors/utils/cdc_store.go @@ -115,6 +115,7 @@ func init() { gob.Register(qvalue.QValueArrayTimestamp{}) gob.Register(qvalue.QValueArrayTimestampTZ{}) gob.Register(qvalue.QValueArrayBoolean{}) + gob.Register(qvalue.QValueTSTZRange{}) } func (c *cdcStore[T]) initPebbleDB() error {