diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go
index 3c60b2f9e4..60e88da450 100644
--- a/internal/querynode/impl.go
+++ b/internal/querynode/impl.go
@@ -188,7 +188,7 @@ func (node *QueryNode) RemoveQueryChannel(ctx context.Context, in *queryPb.Remov
 	return status, nil
 }
 
-// WatchDmChannels create consumers on dmChannels to reveive Incremental data，which is the important part of real-time query
+// WatchDmChannels create consumers on dmChannels to receive Incremental data，which is the important part of real-time query
 func (node *QueryNode) WatchDmChannels(ctx context.Context, in *queryPb.WatchDmChannelsRequest) (*commonpb.Status, error) {
 	code := node.stateCode.Load().(internalpb.StateCode)
 	if code != internalpb.StateCode_Healthy {