diff --git a/pkg/bloomcompactor/batch.go b/pkg/bloomcompactor/batch.go index e0787c1f6f1ec..bed0834a86b74 100644 --- a/pkg/bloomcompactor/batch.go +++ b/pkg/bloomcompactor/batch.go @@ -285,6 +285,7 @@ func (i *blockLoadingIter) Filter(filter func(*bloomshipper.CloseableBlockQuerie func (i *blockLoadingIter) loadNext() bool { // check if there are more overlapping groups to load if !i.overlapping.Next() { + i.iter = v1.NewEmptyIter[*v1.SeriesWithBloom]() return false }