diff --git a/flow/connectors/utils/cdc_records/cdc_records_storage.go b/flow/connectors/utils/cdc_records/cdc_records_storage.go
index 458c5707e0..ae6222c4b8 100644
--- a/flow/connectors/utils/cdc_records/cdc_records_storage.go
+++ b/flow/connectors/utils/cdc_records/cdc_records_storage.go
@@ -18,9 +18,9 @@ import (
 
 const (
 	/** begin with in-memory store, and then switch to Pebble DB
-		when the number of stored records crosses 100k
+		when the number of stored records crosses 2M
 	**/
-	defaultNumRecordsSwitchThreshold = 1_00_000
+	defaultNumRecordsSwitchThreshold = 2_000_000
 )
 
 func encVal(val any) ([]byte, error) {