Deduplication of changelogs in a batch (gluster#4398)

Signed-off-by: Sanju Rakonde <[email protected]>
kohlschuetter · Dec 4, 2024 · 7663679 · 7663679
1 parent 2060330
commit 7663679
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/geo-replication/syncdaemon/primary.py b/geo-replication/syncdaemon/primary.py
@@ -1299,6 +1299,7 @@ def process_change(self, change, done, retry):
             self.batch_stats["DATA_START_TIME"] = time.time()
 
         # sync data
+        datas = datas - self.datas_in_batch
         if datas:
             self.a_syncdata(datas)
             self.datas_in_batch.update(datas)