From a3adb22e10789eabc1bbfba678e883beeaacb043 Mon Sep 17 00:00:00 2001 From: sunby Date: Wed, 27 Jan 2021 09:59:17 +0800 Subject: [PATCH] Change params Signed-off-by: sunby --- internal/dataservice/param.go | 2 +- internal/dataservice/server.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/dataservice/param.go b/internal/dataservice/param.go index 9a574924a8..3455954985 100644 --- a/internal/dataservice/param.go +++ b/internal/dataservice/param.go @@ -182,7 +182,7 @@ func (p *ParamTable) initSegmentInfoChannelName() { func (p *ParamTable) initDataServiceSubscriptionName() { var err error - p.DataServiceSubscriptionName, err = p.Load("msgChannel.chanNamePrefix.dataServiceSubNamePrefix") + p.DataServiceSubscriptionName, err = p.Load("msgChannel.subNamePrefix.dataServiceSubNamePrefix") if err != nil { panic(err) } diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go index 4844b84110..056aaf773f 100644 --- a/internal/dataservice/server.go +++ b/internal/dataservice/server.go @@ -122,14 +122,14 @@ func (s *Server) Start() error { } s.ddHandler = newDDHandler(s.meta, s.segAllocator) s.initSegmentInfoChannel() - if err = s.initMsgProducer(); err != nil { - return err - } if err = s.loadMetaFromMaster(); err != nil { return err } s.startServerLoop() s.waitDataNodeRegister() + if err = s.initMsgProducer(); err != nil { + return err + } s.state.Store(internalpb2.StateCode_HEALTHY) log.Println("start success") return nil