rob sync (#236)

* perform a watermark sync before starting a full differential sync * perform watermark before full-differential sync on interval * remove conditional filter instatiation
aserto-dev · Jan 15, 2024 · 314bbcd · 314bbcd
1 parent 02b5070
commit 314bbcd
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/plugins/edge/sync.go b/plugins/edge/sync.go
@@ -116,9 +116,7 @@ func (s *Sync) Run(fs bool) {
 
 	wm := s.getWatermark(fs)
 
-	if fs {
-		s.filter = cuckoo.NewFilter(wm.getFilterSize())
-	}
+	s.filter = cuckoo.NewFilter(wm.getFilterSize())
 
 	g.Go(func() error {
 		return s.subscriber(wm)