From 2b352bcde51fd0bee55e5d9aa7562bcec743de7f Mon Sep 17 00:00:00 2001 From: congqixia Date: Wed, 22 Dec 2021 14:27:06 +0800 Subject: [PATCH] Fix compact result segment log size always zero (#13953) Signed-off-by: Congqi Xia --- internal/datanode/binlog_io.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/internal/datanode/binlog_io.go b/internal/datanode/binlog_io.go index 6f1d7bdea0..feeefebe2f 100644 --- a/internal/datanode/binlog_io.go +++ b/internal/datanode/binlog_io.go @@ -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, }, },