Fix confused timetick log (#22733) (#22734)

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
pull/22746/head
Jiquan Long 2023-03-14 10:23:54 +08:00 committed by GitHub
parent b3f4c6c25c
commit 6f647b0f08
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions

View File

@ -186,7 +186,7 @@ func (t *timetickSync) updateTimeTick(in *internalpb.ChannelTimeTickMsg, reason
}
if in.Base.SourceID == t.sourceID {
if prev != nil && in.DefaultTimestamp <= prev.defaultTs {
if prev != nil && in.DefaultTimestamp < prev.defaultTs {
log.Warn("timestamp go back", zap.Int64("source id", in.Base.SourceID),
zap.Uint64("curr ts", in.DefaultTimestamp),
zap.Uint64("prev ts", prev.defaultTs),