diff --git a/internal/querycoord/query_coord_test.go b/internal/querycoord/query_coord_test.go index 2dfc0962d5..86fa4b10ba 100644 --- a/internal/querycoord/query_coord_test.go +++ b/internal/querycoord/query_coord_test.go @@ -184,7 +184,7 @@ func TestWatchNodeLoop(t *testing.T) { break } // if session id not exist, means querycoord already handled it and remove - _, err = kv.Load(nodeKey) + _, err = kv.Load(sessionKey) if err != nil { log.Warn("already handled by querycoord", zap.Error(err)) break