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)