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

Close seek function to pass regression test 

Signed-off-by: xige-16 <xi.ge@zilliz.com>
pull/4973/head^2
xige-16 2021-03-11 10:21:24 +08:00 committed by yefu.chen
parent b2b39f5720
commit d35d316056
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
internal/querynode/query_node.go
View File

@ -442,29 +442,29 @@ func (node *QueryNode) LoadSegments(in *queryPb.LoadSegmentRequest) (*commonpb.S
}
// segments are ordered before LoadSegments calling
var position *internalpb2.MsgPosition = nil
//var position *internalpb2.MsgPosition = nil
for i, state := range in.SegmentStates {
thisPosition := state.StartPosition
//thisPosition := state.StartPosition
if state.State <= commonpb.SegmentState_SegmentGrowing {
if position == nil {
position = &internalpb2.MsgPosition{
ChannelName: thisPosition.ChannelName,
}
}
//if position == nil {
// position = &internalpb2.MsgPosition{
// ChannelName: thisPosition.ChannelName,
// }
//}
segmentIDs = segmentIDs[:i]
break
}
position = state.StartPosition
//position = state.StartPosition
}
err = node.dataSyncService.seekSegment(position)
if err != nil {
status := &commonpb.Status{
ErrorCode: commonpb.ErrorCode_UnexpectedError,
Reason: err.Error(),
}
return status, err
}
//err = node.dataSyncService.seekSegment(position)
//if err != nil {
// status := &commonpb.Status{
// ErrorCode: commonpb.ErrorCode_UnexpectedError,
// Reason: err.Error(),
// }
// return status, err
//}
err = node.loadService.loadSegment(collectionID, partitionID, segmentIDs, fieldIDs)
if err != nil {