(skywalking-banyandb) 01/01: Merge remote-tracking branch 'origin/main' into perf/trace-vs-stream

[ha...@apache.org]

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 <ha...@gmail.com>
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
  	}