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