This is an automated email from the ASF dual-hosted git repository. hanahmily pushed a commit to branch index-posting in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
commit 345102f890b110f61ececc7db861441135ec2c0f Merge: 1400dd1 01c28bc Author: Gao Hongtao <[email protected]> AuthorDate: Tue Jul 20 12:58:47 2021 +0800 Merge remote-tracking branch 'origin/main' into index-posting banyand/series/trace/write.go | 3 ++- go.mod | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --cc banyand/series/trace/write.go index 5d28af7,7b78b7d..433be35 --- a/banyand/series/trace/write.go +++ b/banyand/series/trace/write.go @@@ -71,7 -70,7 +71,8 @@@ func (t *traceSeries) Write(seriesID co return 0, errors.Wrap(err, "failed to write chunkID index") } traceIDShardID := partition.ShardID(traceID, t.shardNum) - if err = wp.TimeSeriesWriter(traceIDShardID, traceIndex).Put(traceID, bydb_bytes.Join(convert.Uint16ToBytes(uint16(shardID)), chunkIDBytes), entity.TimestampNanoseconds()); err != nil { - if err = wp.TimeSeriesWriter(traceIDShardID, traceIndex).Put(traceID, chunkIDBytes, entity.TimestampNanoseconds()); err != nil { ++ if err = wp.TimeSeriesWriter(traceIDShardID, traceIndex). ++ Put(traceID, bydb_bytes.Join(convert.Uint16ToBytes(uint16(shardID)), chunkIDBytes), entity.TimestampNanoseconds()); err != nil { return 0, errors.Wrap(err, "failed to Trace index") } err = wp.Writer(shardID, startTimeIndex).Put(bydb_bytes.Join(stateBytes, tsBytes, chunkIDBytes), nil) diff --cc go.mod index 317ce5a,2f971df..1ceb81f --- a/go.mod +++ b/go.mod @@@ -3,7 -3,6 +3,7 @@@ module github.com/apache/skywalking-ban go 1.16 require ( - github.com/RoaringBitmap/roaring v0.9.1 // indirect ++ github.com/RoaringBitmap/roaring v0.9.1 github.com/cespare/xxhash v1.1.0 github.com/dgraph-io/badger/v3 v3.2011.1 github.com/golang/mock v1.3.1
