From ad4f0b6103834aa14cbe40742b9ff9e50c9be671 Mon Sep 17 00:00:00 2001 From: Eric Long Date: Tue, 27 Aug 2019 13:02:49 -0400 Subject: [PATCH] 0004079: Refresh lock for purge service --- .../org/jumpmind/symmetric/service/impl/PurgeService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 37491db6c8..fc8892bebb 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 @@ -440,11 +440,11 @@ private int purgeByMinMax(long[] minMax, long minGapStartId, MinMaxDeleteSql ide log.debug("Deleted {} rows", count); totalCount += count; - if (totalCount > 0 - && (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5)) { + if (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5) { log.info("Purged {} of {} rows so far using {} statements", new Object[] { totalCount, identifier.toString().toLowerCase(), totalDeleteStmts }); ts = System.currentTimeMillis(); + clusterService.refreshLock(ClusterConstants.PURGE_OUTGOING); } minId = maxId + 1; }