Fix lag behind error with 0 servicetime (#21637) (#21899)

Signed-off-by: N yah01 <yang.cen@zilliz.com>

Fix lag behind error with 0 servicetime (#21637) (#21899)
Signed-off-by: N yah01 <yang.cen@zilliz.com>
ebf7455e · yah01 · GitHub · 3b4e5ac2 · ebf7455e
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

internal/querynode/task_read.go internal/querynode/task_read.go +1 -1

未找到文件。
--- 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),