Skip to content

Commit dbaf598

Browse files
authored
Fix collectObjects for updateTableInfo (#21610)
Fix collectObjects for updateTableInfo Approved by: @XuPeng-SH
1 parent a12c319 commit dbaf598

File tree

1 file changed

+11
-4
lines changed

1 file changed

+11
-4
lines changed

pkg/vm/engine/tae/logtail/snapshot.go

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -366,10 +366,17 @@ func (sm *SnapshotMeta) updateTableInfo(
366366
moTable := (*objects)[tid]
367367

368368
// dropped object will overwrite the created object, updating the deleteAt
369-
moTable[id] = &objectInfo{
370-
stats: stats,
371-
createAt: createTS,
372-
deleteAt: deleteTS,
369+
obj := moTable[id]
370+
if obj == nil {
371+
moTable[id] = &objectInfo{
372+
stats: stats,
373+
}
374+
}
375+
if !createTS.IsEmpty() {
376+
moTable[id].createAt = createTS
377+
}
378+
if !deleteTS.IsEmpty() {
379+
moTable[id].deleteAt = deleteTS
373380
}
374381
}
375382
collectObjects(ctx, &objects, nil, data, ckputil.ObjectType_Data, collector)

0 commit comments

Comments
 (0)