milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix var-naming caused by old PRs (#27501) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/27437/head
congqixia 2023-10-07 14:43:32 +08:00 committed by GitHub
parent 8394b3a1ec
commit 80eb5434d3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/datanode/data_sync_service.go
View File

@ -149,7 +149,7 @@ func getSegmentInfos(ctx context.Context, datacoord types.DataCoordClient, segme
SegmentIDs: segmentIDs,
IncludeUnHealthy: true,
})
if err := merr.CheckRpcCall(infoResp, err); err != nil {
if err := merr.CheckRPCCall(infoResp, err); err != nil {
log.Error("Fail to get SegmentInfo by ids from datacoord", zap.Error(err))
return nil, err
}

2
internal/datanode/flow_graph_time_tick_node.go
View File

@ -131,7 +131,7 @@ func (ttn *ttNode) updateChannelCP(channelPos *msgpb.MsgPosition, curTs time.Tim
VChannel: ttn.vChannelName,
Position: channelPos,
})
if err = merr.CheckRpcCall(resp, err); err != nil {
if err = merr.CheckRPCCall(resp, err); err != nil {
log.Warn("UpdateChannelCheckpoint failed", zap.String("channel", ttn.vChannelName),
zap.Time("channelCPTs", channelCPTs), zap.Error(err))
return err

2
pkg/util/merr/utils.go
View File

@ -78,7 +78,7 @@ func Status(err error) *commonpb.Status {
}
}
func CheckRpcCall(resp any, err error) error {
func CheckRPCCall(resp any, err error) error {
if err != nil {
return err
}