admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 01:58:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

enhance: Increase search/query retry times on proxy before timeout (#40438)

Browse Source 
issue: #39379

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
This commit is contained in:
wei liu 2025-06-06 18:12:32 +08:00 committed by GitHub
parent b50c4a7973
commit 8511881d3f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/proxy/lb_policy_test.go
View File

@ -461,7 +461,7 @@ func (s *LBPolicySuite) TestExecute() {
}, },
}) })
s.Error(err) s.Error(err)
s.Equal(int64(11), counter.Load()) s.Equal(int64(26), counter.Load())
// test get shard leader failed // test get shard leader failed
globalMetaCache.DeprecateShardCache(dbName, s.collectionName) globalMetaCache.DeprecateShardCache(dbName, s.collectionName)

2
pkg/util/paramtable/component_param.go
View File

@ -1882,7 +1882,7 @@ please adjust in embedded Milvus: false`,
p.RetryTimesOnReplica = ParamItem{ p.RetryTimesOnReplica = ParamItem{
Key: "proxy.retryTimesOnReplica", Key: "proxy.retryTimesOnReplica",
Version: "2.3.0", Version: "2.3.0",
DefaultValue: "2", DefaultValue: "5",
Doc: "retry times on each replica", Doc: "retry times on each replica",
} }
p.RetryTimesOnReplica.Init(base.mgr) p.RetryTimesOnReplica.Init(base.mgr)

2
pkg/util/paramtable/component_param_test.go
View File

@ -203,7 +203,7 @@ func TestComponentParam(t *testing.T) {
assert.Equal(t, Params.ReplicaSelectionPolicy.GetValue(), "look_aside") assert.Equal(t, Params.ReplicaSelectionPolicy.GetValue(), "look_aside")
assert.Equal(t, Params.CheckQueryNodeHealthInterval.GetAsInt(), 1000) assert.Equal(t, Params.CheckQueryNodeHealthInterval.GetAsInt(), 1000)
assert.Equal(t, Params.CostMetricsExpireTime.GetAsInt(), 1000) assert.Equal(t, Params.CostMetricsExpireTime.GetAsInt(), 1000)
assert.Equal(t, Params.RetryTimesOnReplica.GetAsInt(), 2) assert.Equal(t, Params.RetryTimesOnReplica.GetAsInt(), 5)
assert.EqualValues(t, Params.HealthCheckTimeout.GetAsInt64(), 3000) assert.EqualValues(t, Params.HealthCheckTimeout.GetAsInt64(), 3000)
params.Save("proxy.gracefulStopTimeout", "100") params.Save("proxy.gracefulStopTimeout", "100")