diff --git a/remoting/kubernetes/client.go b/remoting/kubernetes/client.go index 377032ae29ad39ccca5cc05b051f14004edd0c56..b980501490f14762c3175ecd45bba7d540a1933c 100644 --- a/remoting/kubernetes/client.go +++ b/remoting/kubernetes/client.go @@ -69,6 +69,7 @@ func newClient(url common.URL) (*Client, error) { } if r == common.CONSUMER { + // only consumer have to start informer factory c.controller.Run() } return c, nil diff --git a/remoting/kubernetes/registry_controller.go b/remoting/kubernetes/registry_controller.go index 42489cda96901c432a16ddf2485be60bb4ef2713..0fd023d1ef6c4d93ddf7aea98fff3d587aa41138 100644 --- a/remoting/kubernetes/registry_controller.go +++ b/remoting/kubernetes/registry_controller.go @@ -93,7 +93,7 @@ func newDubboRegistryController(ctx context.Context, roleType common.RoleType, k } if err := c.readConfig(); err != nil { - return nil, perrors.WithMessage(err, "dubbo registry controller read config") + return nil, perrors.WithMessage(err, "read config") } if err := c.initCurrentPod(); err != nil { @@ -107,7 +107,7 @@ func newDubboRegistryController(ctx context.Context, roleType common.RoleType, k if roleType == common.CONSUMER { // only consumer need list && watch if err := c.initPodInformer(); err != nil { - return nil, perrors.WithMessage(err, "dubbo registry controller init pod informer") + return nil, perrors.WithMessage(err, "init pod informer") } go c.run() }