From 8f202274a72e29cabf1d34cf3f3c5e8fd6b25b8e Mon Sep 17 00:00:00 2001 From: Xiaofan <83447078+xiaofan-luan@users.noreply.github.com> Date: Thu, 12 Jan 2023 10:53:39 +0800 Subject: [PATCH] Fix lag behind error with 0 servicetime (#21637) Signed-off-by: xiaofan-luan --- internal/querynode/task_read.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/querynode/task_read.go b/internal/querynode/task_read.go index ec20de99f8..e9d6cfc943 100644 --- a/internal/querynode/task_read.go +++ b/internal/querynode/task_read.go @@ -170,7 +170,7 @@ func (b *baseReadTask) Ready() (bool, error) { if guaranteeTs > serviceTime { lag := gt.Sub(st) maxLag := Params.QueryNodeCfg.MaxTimestampLag.GetAsDuration(time.Second) - if lag > maxLag { + if serviceTime != 0 && lag > maxLag { log.Warn("guarantee and servicable ts larger than MaxLag", zap.Time("guaranteeTime", gt), zap.Time("serviceableTime", st),