From 79ccf06cf66629ecee7697c4f4a3b3e8b35bb50a Mon Sep 17 00:00:00 2001 From: wei liu Date: Fri, 18 Aug 2023 14:26:19 +0800 Subject: [PATCH] refine proxy to querynode heartbeat interval (#26426) Signed-off-by: Wei Liu --- configs/milvus.yaml | 2 +- pkg/util/paramtable/component_param.go | 2 +- pkg/util/paramtable/component_param_test.go | 1 + 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/configs/milvus.yaml b/configs/milvus.yaml index 1e668fc22..66cf1027a 100644 --- a/configs/milvus.yaml +++ b/configs/milvus.yaml @@ -176,7 +176,7 @@ rootCoord: # Related configuration of proxy, used to validate client requests and reduce the returned results. proxy: timeTickInterval: 200 # ms, the interval that proxy synchronize the time tick - healthCheckTimetout: 500 # ms, the interval that to do component healthy check + healthCheckTimetout: 3000 # ms, the interval that to do component healthy check msgStream: timeTick: bufSize: 512 diff --git a/pkg/util/paramtable/component_param.go b/pkg/util/paramtable/component_param.go index 2a33e36be..1db214c48 100644 --- a/pkg/util/paramtable/component_param.go +++ b/pkg/util/paramtable/component_param.go @@ -904,7 +904,7 @@ func (p *proxyConfig) init(base *BaseTable) { p.HealthCheckTimetout = ParamItem{ Key: "proxy.healthCheckTimetout", Version: "2.3.0", - DefaultValue: "1000", + DefaultValue: "3000", PanicIfEmpty: true, Doc: "ms, the interval that to do component healthy check", Export: true, diff --git a/pkg/util/paramtable/component_param_test.go b/pkg/util/paramtable/component_param_test.go index 248cb6778..1b0cd3045 100644 --- a/pkg/util/paramtable/component_param_test.go +++ b/pkg/util/paramtable/component_param_test.go @@ -166,6 +166,7 @@ func TestComponentParam(t *testing.T) { assert.Equal(t, Params.CheckQueryNodeHealthInterval.GetAsInt(), 1000) assert.Equal(t, Params.CostMetricsExpireTime.GetAsInt(), 1000) assert.Equal(t, Params.RetryTimesOnReplica.GetAsInt(), 2) + assert.Equal(t, Params.HealthCheckTimetout.GetAsInt64(), 3000) }) // t.Run("test proxyConfig panic", func(t *testing.T) { -- GitLab