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

Call segmentLoadDeletedRecord in segment_loader (#10472) 

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
pull/10495/head
yukun 2021-10-23 09:31:10 +08:00 committed by GitHub
parent 36d3b7d9e5
commit 6949350b8b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
internal/querynode/segment_loader.go
View File

@ -335,14 +335,17 @@ func (loader *segmentLoader) loadDeltaLogs(segment *Segment, deltaLogs []*datapb
return err
}
//rowCount := len(deltaData.Data)
rowCount := len(deltaData.Data)
pks := make([]int64, 0)
tss := make([]int64, 0)
tss := make([]Timestamp, 0)
for pk, ts := range deltaData.Data {
pks = append(pks, pk)
tss = append(tss, ts)
tss = append(tss, Timestamp(ts))
}
err = segment.segmentLoadDeletedRecord(pks, tss, int64(rowCount))
if err != nil {
return err
}
//segment.Delete(pks, tss, rowCount)
return nil
}