From ebf7455e54f0c7b64363672d3beb7494d983a473 Mon Sep 17 00:00:00 2001 From: yah01 Date: Wed, 1 Feb 2023 14:25:51 +0800 Subject: [PATCH] Fix lag behind error with 0 servicetime (#21637) (#21899) Signed-off-by: yah01 --- 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 e52690fe57..79b23cdc12 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 - 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),