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),