From a1151d9bf51280ddfd0e32d76d53754c777946d1 Mon Sep 17 00:00:00 2001 From: sunby Date: Tue, 5 Jan 2021 11:31:42 +0800 Subject: [PATCH] Change kvRootPath to MetaRootPath in master Signed-off-by: sunby --- internal/master/master.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/master/master.go b/internal/master/master.go index 90093cc22e..5476a7c8dc 100644 --- a/internal/master/master.go +++ b/internal/master/master.go @@ -181,7 +181,7 @@ func CreateServer(ctx context.Context) (*Master, error) { m.scheduler.SetDDMsgStream(pulsarDDStream) m.scheduler.SetIDAllocator(func() (UniqueID, error) { return m.idAllocator.AllocOne() }) - flushClient, err := writerclient.NewWriterClient(Params.EtcdAddress, kvRootPath, Params.WriteNodeSegKvSubPath, pulsarDDStream) + flushClient, err := writerclient.NewWriterClient(Params.EtcdAddress, Params.MetaRootPath, Params.WriteNodeSegKvSubPath, pulsarDDStream) if err != nil { return nil, err }