diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java
index 8a06c1e2d6..e893dc7313 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java
@@ -192,7 +192,7 @@ private long purgeDataRows(final Calendar time) {
     private long[] queryForMinMax(String sql, Object... params) {
         long[] minMax = sqlTemplate.queryForObject(sql, new ISqlRowMapper<long[]>() {
             public long[] mapRow(Row rs) {
-                return new long[] { rs.getLong("min_id"), rs.getLong("max_id") };
+                return new long[] { rs.getLong("min_id"), rs.getLong("max_id")-1 };
             }
         }, params);
         return minMax;