diff --git a/internal/datanode/channel_meta.go b/internal/datanode/channel_meta.go index 3251120166..95364ed793 100644 --- a/internal/datanode/channel_meta.go +++ b/internal/datanode/channel_meta.go @@ -209,6 +209,7 @@ func (c *ChannelMeta) addSegment(req addSegmentReq) error { historyInsertBuf: make([]*BufferData, 0), historyDeleteBuf: make([]*DelDataBuf, 0), startPos: req.startPos, + lastSyncTs: req.recoverTs, } seg.setType(req.segType) // Set up pk stats