diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java index 8ae8dce8d5..932fe5dbdd 100644 --- a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java +++ b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java @@ -176,6 +176,7 @@ private void purgeBatchesOlderThan(final Calendar time) { .getTime() }, Integer.class); int eventRowCount = 0; int dataIdCount = 0; + int batchesPurged = 0; long ts = System.currentTimeMillis(); for (final Integer batchId : batchIds) { do { @@ -199,12 +200,12 @@ public Object doInTransaction(final TransactionStatus s) { eventRowCount += dataIdCount; if (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5) { - logger.info("Purged " + batchIds.size() + " a total of batches and " + eventRowCount + logger.info("Purged " + batchesPurged + " out of " + batchIds.size() + " total and " + eventRowCount + " data_events."); ts = System.currentTimeMillis(); } } while (dataIdCount > 0); - + batchesPurged++; } if (batchIds.size() > 0) {