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

[skip e2e]Fix redundant conversion (#13648) 

Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>
pull/13675/head
godchen 2021-12-17 22:28:50 +08:00 committed by GitHub
parent a965bdf325
commit 154f11e3a1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/datanode/compactor.go
View File

@ -143,19 +143,19 @@ func (t *compactionTask) mergeDeltalogs(dBlobs map[UniqueID][]*Blob, timetravelT
pk := dData.Pks[i]
ts := dData.Tss[i]
if timetravelTs != Timestamp(0) && Timestamp(dData.Tss[i]) <= timetravelTs {
if timetravelTs != Timestamp(0) && dData.Tss[i] <= timetravelTs {
pk2ts[pk] = ts
continue
}
dbuff.delData.Append(pk, ts)
if Timestamp(ts) < dbuff.tsFrom {
dbuff.tsFrom = Timestamp(ts)
if ts < dbuff.tsFrom {
dbuff.tsFrom = ts
}
if Timestamp(ts) > dbuff.tsTo {
dbuff.tsTo = Timestamp(ts)
if ts > dbuff.tsTo {
dbuff.tsTo = ts
}
}
}