From 76c88d8d49edf2d288a064912a1cd6e00f32a1de Mon Sep 17 00:00:00 2001 From: Wenkai Yin Date: Fri, 8 Dec 2017 15:30:41 +0800 Subject: [PATCH] Fix bugs of replicaton --- src/replication/core/controller.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/replication/core/controller.go b/src/replication/core/controller.go index 17e40d8fd..638c41553 100644 --- a/src/replication/core/controller.go +++ b/src/replication/core/controller.go @@ -83,7 +83,7 @@ func NewDefaultController(cfg ControllerConfig) *DefaultController { triggerManager: trigger.NewManager(cfg.CacheCapacity), } - endpoint := config.InternalJobServiceURL() + endpoint := "http://jobservice" client := client.NewAuthorizedClient(auth.NewSecretAuthorizer(config.UISecret())) ctl.replicator = replicator.NewDefaultReplicator(endpoint, client)