fix ut

Signed-off-by: bigsheeper <[email protected]>

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:

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 {