This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
The following commit(s) were added to refs/heads/main by this push:
new 03d413b7 Write index before core trace storage (#751)
03d413b7 is described below
commit 03d413b7083a7198be437bf5cf7b7b1b48e820fa
Author: Huang Youliang <butterbright0...@gmail.com>
AuthorDate: Fri Sep 5 07:36:06 2025 +0800
Write index before core trace storage (#751)
---
banyand/trace/write_standalone.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/banyand/trace/write_standalone.go
b/banyand/trace/write_standalone.go
index 47c4b941..b2abd73b 100644
--- a/banyand/trace/write_standalone.go
+++ b/banyand/trace/write_standalone.go
@@ -355,7 +355,6 @@ func (w *writeCallback) Rev(ctx context.Context, message
bus.Message) (resp bus.
g := groups[i]
for j := range g.tables {
es := g.tables[j]
- es.tsTable.mustAddTraces(es.traces)
for sidxName, sidxReqs := range es.sidxReqsMap {
if len(sidxReqs) > 0 {
sidxInstance, err :=
es.tsTable.getOrCreateSidx(sidxName)
@@ -373,6 +372,7 @@ func (w *writeCallback) Rev(ctx context.Context, message
bus.Message) (resp bus.
w.l.Error().Err(err).Msg("cannot write
series index")
}
}
+ es.tsTable.mustAddTraces(es.traces)
releaseTraces(es.traces)
}
if len(g.segments) > 0 {
