Fix Delta log loss after compaction (#17634)

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
pull/17634/merge
Xiaofan 2022-06-19 20:12:11 +08:00 committed by GitHub
parent 50cecc65ed
commit 516d91470f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions

View File

@ -795,7 +795,7 @@ func (m *meta) CompleteMergeCompaction(compactionLogs []*datapb.CompactionSegmen
var startPosition, dmlPosition *internalpb.MsgPosition
for _, s := range segments {
if dmlPosition == nil || s.GetDmlPosition().Timestamp > dmlPosition.Timestamp {
if dmlPosition == nil || s.GetDmlPosition().Timestamp < dmlPosition.Timestamp {
dmlPosition = s.GetDmlPosition()
}