milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix compact result segment log size always zero (#13953) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/13943/head
congqixia 2021-12-22 14:27:06 +08:00 committed by GitHub
parent c36439b13e
commit 2b352bcde5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/datanode/binlog_io.go
View File

@ -233,11 +233,15 @@ func (b *binlogIO) genInsertBlobs(data *InsertData, partID, segID UniqueID, meta
k := JoinIDPath(meta.GetID(), partID, segID, fID, <-generator)
key := path.Join(Params.InsertBinlogRootPath, k)
kvs[key] = bytes.NewBuffer(blob.GetValue()).String()
value := bytes.NewBuffer(blob.GetValue()).String()
fileLen := len(value)
kvs[key] = value
inpaths = append(inpaths, &datapb.FieldBinlog{
FieldID: fID,
Binlogs: []*datapb.Binlog{
{
LogSize: int64(fileLen),
LogPath: key,
},
},
@ -251,11 +255,16 @@ func (b *binlogIO) genInsertBlobs(data *InsertData, partID, segID UniqueID, meta
k := JoinIDPath(meta.GetID(), partID, segID, fID, <-generator)
key := path.Join(Params.StatsBinlogRootPath, k)
kvs[key] = bytes.NewBuffer(blob.GetValue()).String()
value := bytes.NewBuffer(blob.GetValue()).String()
fileLen := len(value)
kvs[key] = value
statspaths = append(statspaths, &datapb.FieldBinlog{
FieldID: fID,
Binlogs: []*datapb.Binlog{
{
LogSize: int64(fileLen),
LogPath: key,
},
},