From 0527743f8981ad56634fccbe1a77966a2ff15887 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Mon, 30 Dec 2024 19:53:10 +0800 Subject: [PATCH] fix ut Signed-off-by: bigsheeper --- configs/milvus.yaml | 4 ++-- internal/util/pipeline/stream_pipeline_test.go | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/configs/milvus.yaml b/configs/milvus.yaml index 48d3bb250a55b..59b04ed1d84cc 100644 --- a/configs/milvus.yaml +++ b/configs/milvus.yaml @@ -177,8 +177,8 @@ mq: targetBufSize: 16 # the lenth of channel buffer for targe maxTolerantLag: 3 # Default value: "3", the timeout(in seconds) that target sends msgPack maxDispatcherNumPerPchannel: 10 # The maximum number of dispatchers per physical channel, primarily to limit the number of consumers and prevent performance issues(e.g., during recovery when a large number of channels are watched). - retrySleep: 300 # register retry sleep time in seconds - retryTimeout: 5 # register retry timeout in seconds + retrySleep: 5 # register retry sleep time in seconds + retryTimeout: 300 # register retry timeout in seconds # Related configuration of pulsar, used to manage Milvus logs of recent mutation operations, output streaming log, and provide log publish-subscribe services. pulsar: diff --git a/internal/util/pipeline/stream_pipeline_test.go b/internal/util/pipeline/stream_pipeline_test.go index b77bfae9f9dc9..41154f3728ac1 100644 --- a/internal/util/pipeline/stream_pipeline_test.go +++ b/internal/util/pipeline/stream_pipeline_test.go @@ -21,14 +21,13 @@ import ( "fmt" "testing" - "github.com/milvus-io/milvus/pkg/util/paramtable" - "github.com/stretchr/testify/mock" "github.com/stretchr/testify/suite" "github.com/milvus-io/milvus-proto/go-api/v2/msgpb" "github.com/milvus-io/milvus/pkg/mq/msgdispatcher" "github.com/milvus-io/milvus/pkg/mq/msgstream" + "github.com/milvus-io/milvus/pkg/util/paramtable" ) type StreamPipelineSuite struct {