diff --git a/internal/datanode/channel_meta.go b/internal/datanode/channel_meta.go index 4abf77d785..865b9c3fd8 100644 --- a/internal/datanode/channel_meta.go +++ b/internal/datanode/channel_meta.go @@ -516,6 +516,8 @@ func (c *ChannelMeta) mergeFlushedSegments(seg *Segment, planID UniqueID, compac s := c.segments[ID] s.compactedTo = seg.segmentID s.setType(datapb.SegmentType_Compacted) + // release bloom filter + s.pkStat.pkFilter = nil } c.segMu.Unlock()