From 62a43d0dd3c48fa50ef72b6549c085e5ed6e87b8 Mon Sep 17 00:00:00 2001 From: congqixia Date: Thu, 28 Oct 2021 19:18:24 +0800 Subject: [PATCH] Fix log does=>dose typo (#10829) Signed-off-by: Congqi Xia --- internal/querynode/flow_graph_filter_dm_node.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/querynode/flow_graph_filter_dm_node.go b/internal/querynode/flow_graph_filter_dm_node.go index af1cbc5494..9b59241485 100644 --- a/internal/querynode/flow_graph_filter_dm_node.go +++ b/internal/querynode/flow_graph_filter_dm_node.go @@ -103,13 +103,13 @@ func (fdmNode *filterDmNode) filterInvalidDeleteMessage(msg *msgstream.DeleteMsg collection := fdmNode.replica.hasCollection(msg.CollectionID) partition := fdmNode.replica.hasPartition(msg.PartitionID) 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("partitionID", msg.PartitionID)) return nil } 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("partitionID", msg.PartitionID)) return nil @@ -162,14 +162,14 @@ func (fdmNode *filterDmNode) filterInvalidInsertMessage(msg *msgstream.InsertMsg collection := fdmNode.replica.hasCollection(msg.CollectionID) partition := fdmNode.replica.hasPartition(msg.PartitionID) 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("partitionID", msg.PartitionID)) return nil } 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("partitionID", msg.PartitionID)) return nil