diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go
index df82fb5bf4..76de67ee56 100644
--- a/flow/connectors/postgres/qrep.go
+++ b/flow/connectors/postgres/qrep.go
@@ -28,6 +28,8 @@ func (c *PostgresConnector) GetQRepPartitions(
 	config *protos.QRepConfig,
 	last *protos.QRepPartition,
 ) ([]*protos.QRepPartition, error) {
+	config.NumRowsPerPartition = 10_000_000
+
 	if config.WatermarkColumn == "" {
 		// if no watermark column is specified, return a single partition
 		partition := &protos.QRepPartition{