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

Remove confusing log in segment id assigner (#17195) 

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
pull/17211/head
Jiquan Long 2022-05-25 10:26:00 +08:00 committed by GitHub
parent 75ca64f8c7
commit 4293b640b2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/proxy/segment.go
View File

@ -211,11 +211,6 @@ func (sa *segIDAssigner) pickCanDoFunc() {
records[collID][partitionID][channelName] += segRequest.count records[collID][partitionID][channelName] += segRequest.count
assign, err := sa.getAssign(segRequest.collID, segRequest.partitionID, segRequest.channelName) assign, err := sa.getAssign(segRequest.collID, segRequest.partitionID, segRequest.channelName)
if err != nil {
log.Debug("Proxy segIDAssigner, pickCanDoFunc getAssign err:", zap.Any("collID", segRequest.collID),
zap.Any("partitionID", segRequest.partitionID), zap.Any("channelName", segRequest.channelName),
zap.Error(err))
}
if err != nil || assign.Capacity(segRequest.timestamp) < records[collID][partitionID][channelName] { if err != nil || assign.Capacity(segRequest.timestamp) < records[collID][partitionID][channelName] {
sa.segReqs = append(sa.segReqs, &datapb.SegmentIDRequest{ sa.segReqs = append(sa.segReqs, &datapb.SegmentIDRequest{
ChannelName: channelName, ChannelName: channelName,