fix: update timestamp generation logic in handlePack function (#187)

zilliztech · Mar 5, 2025 · a665e21 · a665e21
1 parent 6651775
commit a665e21
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/reader/replicate_channel_manager.go b/core/reader/replicate_channel_manager.go
@@ -1745,8 +1745,8 @@ func (r *replicateChannelHandler) handlePack(forward bool, pack *msgstream.MsgPa
 		return nil
 	}
 	GetTSManager().UnsafeUpdatePackTS(tsManagerChannelKey, newPack.BeginTs, func(newTS uint64) (uint64, bool) {
-		generateTS = newTS
 		reset := resetMsgPackTimestamp(newPack, newTS)
+		generateTS = newPack.EndTs
 		return newPack.EndTs, reset
 	})