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 12e8426a0eab69890b8b79f69adecf1e08ec8d4c Merge: 5e9fe68b 071c0ccd Author: Gao Hongtao <[email protected]> AuthorDate: Mon Sep 29 22:56:18 2025 +0000 Merge remote-tracking branch 'origin/main' into perf/trace-vs-stream banyand/internal/sidx/sidx.go | 6 ++ banyand/trace/flusher.go | 5 ++ banyand/trace/syncer.go | 70 +++++++++++++++------- banyand/trace/write_data.go | 2 + pkg/test/setup/setup.go | 4 ++ .../distributed/query/query_suite_test.go | 5 ++ 6 files changed, 70 insertions(+), 22 deletions(-) diff --cc banyand/internal/sidx/sidx.go index 14f3b8ec,5e2efd1f..64777d6b --- a/banyand/internal/sidx/sidx.go +++ b/banyand/internal/sidx/sidx.go @@@ -453,8 -453,13 +453,14 @@@ func (s *sidx) Flush() error } partPath := partPath(s.root, pw.ID()) pw.mp.mustFlush(s.fileSystem, partPath) + if l := s.l.Debug(); l.Enabled() { + s.l.Debug(). + Uint64("part_id", pw.ID()). + Str("part_path", partPath). + Msg("flushing sidx part") + } newPW := newPartWrapper(nil, mustOpenPart(partPath, s.fileSystem)) + newPW.p.partMetadata.ID = pw.ID() flushIntro.flushed[newPW.ID()] = newPW }
