This is an automated email from the ASF dual-hosted git repository. hanahmily pushed a commit to branch perf/trace-vs-stream in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
commit 93cd8d099b303810daa4687ee428ec305838a950 Author: Gao Hongtao <[email protected]> AuthorDate: Sat Sep 27 10:10:44 2025 +0000 debugging oom --- banyand/trace/snapshot.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/banyand/trace/snapshot.go b/banyand/trace/snapshot.go index bc0ee241..6f873ffe 100644 --- a/banyand/trace/snapshot.go +++ b/banyand/trace/snapshot.go @@ -118,6 +118,7 @@ func (s *snapshot) remove(nextEpoch uint64, merged map[partHandle]struct{}) snap var result snapshot result.epoch = nextEpoch result.ref = 1 + var removedCount int for i := 0; i < len(s.parts); i++ { if _, ok := merged[partHandle{partID: s.parts[i].ID(), partType: PartTypeCore}]; !ok { s.parts[i].incRef() @@ -125,7 +126,9 @@ func (s *snapshot) remove(nextEpoch uint64, merged map[partHandle]struct{}) snap continue } s.parts[i].removable.Store(true) + removedCount++ } + logger.Infof("removed %d parts, merged %d parts", removedCount, len(merged)) return result }
