mirror of https://github.com/milvus-io/milvus.git
[skip e2e]Fix comment typo (#14178)
Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>pull/14128/merge
parent
c337ae23b6
commit
08102b8945
|
@ -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 {
|
||||
|
|
Loading…
Reference in New Issue