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

Fix log does=>dose typo (#10829) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/10842/head
congqixia 2021-10-28 19:18:24 +08:00 committed by GitHub
parent 756be81bce
commit 62a43d0dd3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/querynode/flow_graph_filter_dm_node.go
View File

@ -103,13 +103,13 @@ func (fdmNode *filterDmNode) filterInvalidDeleteMessage(msg *msgstream.DeleteMsg
collection := fdmNode.replica.hasCollection(msg.CollectionID) collection := fdmNode.replica.hasCollection(msg.CollectionID)
partition := fdmNode.replica.hasPartition(msg.PartitionID) partition := fdmNode.replica.hasPartition(msg.PartitionID)
if fdmNode.loadType == loadTypeCollection && !collection { if fdmNode.loadType == loadTypeCollection && !collection {
log.Debug("filter invalid delete message, collection dose not exist", log.Debug("filter invalid delete message, collection does not exist",
zap.Any("collectionID", msg.CollectionID), zap.Any("collectionID", msg.CollectionID),
zap.Any("partitionID", msg.PartitionID)) zap.Any("partitionID", msg.PartitionID))
return nil return nil
} }
if fdmNode.loadType == loadTypePartition && !partition { if fdmNode.loadType == loadTypePartition && !partition {
log.Debug("filter invalid delete message, partition dose not exist", log.Debug("filter invalid delete message, partition does not exist",
zap.Any("collectionID", msg.CollectionID), zap.Any("collectionID", msg.CollectionID),
zap.Any("partitionID", msg.PartitionID)) zap.Any("partitionID", msg.PartitionID))
return nil return nil
@ -162,14 +162,14 @@ func (fdmNode *filterDmNode) filterInvalidInsertMessage(msg *msgstream.InsertMsg
collection := fdmNode.replica.hasCollection(msg.CollectionID) collection := fdmNode.replica.hasCollection(msg.CollectionID)
partition := fdmNode.replica.hasPartition(msg.PartitionID) partition := fdmNode.replica.hasPartition(msg.PartitionID)
if fdmNode.loadType == loadTypeCollection && !collection { if fdmNode.loadType == loadTypeCollection && !collection {
log.Debug("filter invalid insert message, collection dose not exist", log.Debug("filter invalid insert message, collection does not exist",
zap.Any("collectionID", msg.CollectionID), zap.Any("collectionID", msg.CollectionID),
zap.Any("partitionID", msg.PartitionID)) zap.Any("partitionID", msg.PartitionID))
return nil return nil
} }
if fdmNode.loadType == loadTypePartition && !partition { if fdmNode.loadType == loadTypePartition && !partition {
log.Debug("filter invalid insert message, partition dose not exist", log.Debug("filter invalid insert message, partition does not exist",
zap.Any("collectionID", msg.CollectionID), zap.Any("collectionID", msg.CollectionID),
zap.Any("partitionID", msg.PartitionID)) zap.Any("partitionID", msg.PartitionID))
return nil return nil