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

fix: Print number of pks instead of delete pk val (#29653) 

See also #29445

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/29674/head
congqixia 2024-01-04 10:02:46 +08:00 committed by GitHub
parent 6bf46c6fac
commit cf228c2f1c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/datanode/flow_graph_delete_node.go
View File

@ -169,7 +169,9 @@ func (dn *deleteNode) Operate(in []Msg) []Msg {
}
func (dn *deleteNode) bufferDeleteMsg(msg *msgstream.DeleteMsg, tr TimeRange, startPos, endPos *msgpb.MsgPosition) ([]UniqueID, error) {
log.Debug("bufferDeleteMsg", zap.Any("primary keys", msg.PrimaryKeys), zap.String("vChannelName", dn.channelName))
log.Debug("bufferDeleteMsg",
zap.Int("pkNum", typeutil.GetSizeOfIDs(msg.GetPrimaryKeys())),
zap.String("vChannelName", dn.channelName))
primaryKeys := storage.ParseIDs2PrimaryKeys(msg.PrimaryKeys)
segIDToPks, segIDToTss := dn.filterSegmentByPK(msg.PartitionID, primaryKeys, msg.Timestamps)