diff --git a/internal/dataservice/server_test.go b/internal/dataservice/server_test.go index 4b87ced64a..e0875082d0 100644 --- a/internal/dataservice/server_test.go +++ b/internal/dataservice/server_test.go @@ -13,9 +13,12 @@ import ( "context" "math" "path" + "strconv" "testing" "time" + "math/rand" + "github.com/milvus-io/milvus/internal/msgstream" "github.com/milvus-io/milvus/internal/proto/commonpb" "github.com/milvus-io/milvus/internal/proto/datapb" @@ -831,6 +834,8 @@ func TestGetRecoveryInfo(t *testing.T) { func newTestServer(t *testing.T, receiveCh chan interface{}) *Server { Params.Init() + Params.TimeTickChannelName += strconv.Itoa(rand.Int()) + Params.StatisticsChannelName += strconv.Itoa(rand.Int()) var err error factory := msgstream.NewPmsFactory() m := map[string]interface{}{