fix:fix delete record assert failed

Signed-off-by: luzhang <[email protected]>
milvus-io · Dec 19, 2024 · 6edde81 · 6edde81
1 parent b537a72
commit 6edde81
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/internal/core/src/segcore/DeletedRecord.h b/internal/core/src/segcore/DeletedRecord.h
@@ -83,9 +83,17 @@ class DeletedRecord {
         InternalPush(pks, timestamps);
 
         SortedDeleteList::Accessor accessor(deleted_lists_);
-        auto* last = accessor.last();
-        Assert(last != nullptr);
-        max_load_timestamp_ = last->first;
+        if (!deleted_lists_->empty()) {
+            auto* last = accessor.last();
+            Assert(last != nullptr);
+            max_load_timestamp_ = last->first;
+        } else {
+            for (size_t i = 0; i < pks.size(); ++i) {
+                if (timestamps[i] > max_load_timestamp_) {
+                    max_load_timestamp_ = timestamps[i];
+                }
+            }
+        }
 
         //TODO: add support for dump snapshot when load finished
     }