real fix

PeerDB-io · Oct 25, 2023 · 0959f65 · 0959f65
1 parent 92a496e
commit 0959f65
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go
@@ -100,7 +100,7 @@ func (c *PostgresConnector) getNumRowsPartitions(
 		// if there is no last partition, we will return a partition with the min and max values
 		// if there is a last partition, we will return a partition with the last partition's end value + 1 and the max value
 		if last != nil && last.Range != nil {
-			maxValInt += 1
+			minValInt += 1
 			minVal = minValInt
 		}