From 0959f65873f4ed8585b5ff79972b052c2b8044d5 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Wed, 25 Oct 2023 17:48:58 -0400 Subject: [PATCH] real fix --- flow/connectors/postgres/qrep.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go index abc4fa9a1e..af272e4a0f 100644 --- 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 }