From 6f647b0f08ccf563b4fe78d43c6dd0dd7743fb51 Mon Sep 17 00:00:00 2001 From: Jiquan Long Date: Tue, 14 Mar 2023 10:23:54 +0800 Subject: [PATCH] Fix confused timetick log (#22733) (#22734) Signed-off-by: longjiquan --- internal/rootcoord/timeticksync.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/rootcoord/timeticksync.go b/internal/rootcoord/timeticksync.go index a596ed6079..ff2ba3c3d2 100644 --- a/internal/rootcoord/timeticksync.go +++ b/internal/rootcoord/timeticksync.go @@ -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),