Skip to content

Commit

Permalink
fix: [skip e2e]Increase graceful time to ensure that bounded search e…
Browse files Browse the repository at this point in the history
…xecuting normally (milvus-io#31064)

issue: milvus-io#31063 
Increase the graceful time to ensure that bounded query requests can be
executed normally in the event of RootCoord failure.

Signed-off-by: Cai Zhang <[email protected]>
  • Loading branch information
xiaocai2333 authored Mar 7, 2024
1 parent 8ff8fef commit 951c91c
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ import (
"github.com/milvus-io/milvus/pkg/util/funcutil"
"github.com/milvus-io/milvus/pkg/util/merr"
"github.com/milvus-io/milvus/pkg/util/metric"
"github.com/milvus-io/milvus/pkg/util/paramtable"
"github.com/milvus-io/milvus/tests/integration"
)

Expand Down Expand Up @@ -279,6 +280,9 @@ func (s *CoordDownSearch) searchAfterCoordDown() float64 {
var err error
c := s.Cluster

params := paramtable.Get()
paramtable.Init()

start := time.Now()
log.Info("=========================Data Coordinators stopped=========================")
c.DataCoord.Stop()
Expand All @@ -294,8 +298,10 @@ func (s *CoordDownSearch) searchAfterCoordDown() float64 {

log.Info("=========================Root Coordinators stopped=========================")
c.RootCoord.Stop()
params.Save(params.CommonCfg.GracefulTime.Key, "60000")
s.search(searchCollectionName, Dim, commonpb.ConsistencyLevel_Bounded)
s.search(searchCollectionName, Dim, commonpb.ConsistencyLevel_Eventually)
params.Reset(params.CommonCfg.GracefulTime.Key)
failedStart := time.Now()
s.searchFailed(searchCollectionName, Dim, commonpb.ConsistencyLevel_Strong)
log.Info(fmt.Sprintf("=========================Failed search cost: %fs=========================", time.Since(failedStart).Seconds()))
Expand Down

0 comments on commit 951c91c

Please sign in to comment.