mirror of https://github.com/milvus-io/milvus.git
[skip e2e]Fix comment typo (#14177)
Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>pull/14200/head
parent
8a2c3ecefd
commit
acd792515d
|
@ -238,7 +238,7 @@ func (node *QueryNode) WatchDmChannels(ctx context.Context, in *queryPb.WatchDmC
|
|||
return waitFunc()
|
||||
}
|
||||
|
||||
// WatchDeltaChannels create consumers on dmChannels to reveive Incremental data,which is the important part of real-time query
|
||||
// WatchDeltaChannels create consumers on dmChannels to receive Incremental data,which is the important part of real-time query
|
||||
func (node *QueryNode) WatchDeltaChannels(ctx context.Context, in *queryPb.WatchDeltaChannelsRequest) (*commonpb.Status, error) {
|
||||
code := node.stateCode.Load().(internalpb.StateCode)
|
||||
if code != internalpb.StateCode_Healthy {
|
||||
|
|
Loading…
Reference in New Issue