From ce338556526a095c2ec8ad46de360ae22ced77d2 Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Fri, 10 Sep 2021 14:46:00 +0800 Subject: [PATCH] [skip-ci]Fix datanode comment typo (#7689) Signed-off-by: yangxuan --- internal/datanode/data_node.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go index 71f74bb8f7..a00585cb5d 100644 --- a/internal/datanode/data_node.go +++ b/internal/datanode/data_node.go @@ -67,8 +67,8 @@ const illegalRequestErrStr = "Illegal request" // services in datanode package. // // DataNode implements `types.Component`, `types.DataNode` interfaces. -// `rootCoord` is grpc client of root coordinator. -// `dataCoord` is grpc client of data service. +// `rootCoord` is a grpc client of root coordinator. +// `dataCoord` is a grpc client of data service. // `NodeID` is unique to each datanode. // `State` is current statement of this data node, indicating whether it's healthy. // @@ -198,7 +198,7 @@ func (node *DataNode) StartWatchChannels(ctx context.Context) { } } -// handleChannelEvt handels event from kv watch event +// handleChannelEvt handles event from kv watch event func (node *DataNode) handleChannelEvt(evt *clientv3.Event) { switch evt.Type { case clientv3.EventTypePut: // datacoord shall put channels needs to be watched here @@ -226,7 +226,7 @@ func (node *DataNode) handleChannelEvt(evt *clientv3.Event) { if err != nil { log.Warn("fail to change WatchState to complete", zap.String("key", string(evt.Kv.Key)), zap.Error(err)) node.ReleaseDataSyncService(string(evt.Kv.Key)) - // maybe retry logic and exit logic + // TODO GOOSE: maybe retry logic and exit logic } case clientv3.EventTypeDelete: // guaranteed there is no "/" in channel name