diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java index 6a03492fe7..531f7955b6 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java @@ -413,7 +413,7 @@ protected void fixOverlappingGaps(List gapsToCheck, ProcessInfo process dataService.deleteDataGap(transaction, curGap); gapsCopy.remove(i--); } else { - if (lastGap == null && curGap.gapSize() >= maxDataToSelect - 1) { + if (lastGap == null && curGap.gapSize() >= maxDataToSelect - 1 && gapsCopy.get(gapsCopy.size() - 1).gapSize() < maxDataToSelect - 1) { lastGap = curGap; } if (prevGap != null) {