From 45cbec1f7bddf61c4694e03db62c0e52b3fb8355 Mon Sep 17 00:00:00 2001 From: "edward.zeng" Date: Thu, 2 Dec 2021 19:11:32 +0800 Subject: [PATCH] [skip ci] Refine datanode binlog io comment (#12638) Signed-off-by: Edward Zeng --- internal/datanode/binlog_io.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/binlog_io.go b/internal/datanode/binlog_io.go index af4a2b6928..5f2d070a86 100644 --- a/internal/datanode/binlog_io.go +++ b/internal/datanode/binlog_io.go @@ -195,7 +195,7 @@ func (b *binlogIO) genDeltaBlobs(data *DeleteData, collID, partID, segID UniqueI return key, blob.GetValue(), nil } -// return kvs, insert-paths, stats-paths +// genInsertBlobs returns kvs, insert-paths, stats-paths func (b *binlogIO) genInsertBlobs(data *InsertData, partID, segID UniqueID, meta *etcdpb.CollectionMeta) (map[string]string, []*datapb.FieldBinlog, []*datapb.FieldBinlog, error) { inCodec := storage.NewInsertCodec(meta) inlogs, statslogs, err := inCodec.Serialize(partID, segID, data)