fix

uber-archive · Feb 17, 2017 · 35d9a36 · 35d9a36
1 parent 8aae5d5
commit 35d9a36
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/services/replicator/metadataReconciler.go b/services/replicator/metadataReconciler.go
@@ -621,7 +621,7 @@ func (r *metadataReconciler) sealExtentInStore(destUUID string, extentUUID strin
 
 	var errorOccured bool
 	for _, store := range readExtentResult.GetExtentStats().GetExtent().GetStoreUUIDs() {
-		storeClient, _, err := r.replicator.clientFactory.GetThriftStoreClientUUID(store, destUUID)
+		storeClient, _, err := r.replicator.GetClientFactory().GetThriftStoreClientUUID(store, destUUID)
 		if err != nil {
 			lclLg.WithFields(bark.Fields{
 				common.TagErr:  err,

diff --git a/services/replicator/replicator.go b/services/replicator/replicator.go
@@ -61,7 +61,6 @@ type (
 		tenancy                   string
 		defaultAuthoritativeZone  string
 		replicatorclientFactory   ClientFactory
-		clientFactory             common.ClientFactory
 		remoteReplicatorConn      map[string]*outConnection
 		remoteReplicatorConnMutex sync.RWMutex
 		storehostConn             map[string]*outConnection
@@ -141,7 +140,6 @@ func (r *Replicator) Start(thriftService []thrift.TChanServer) {
 	r.hostIDHeartbeater = common.NewHostIDHeartbeater(r.metaClient, r.GetHostUUID(), r.GetHostPort(), r.GetHostName(), r.logger)
 	r.hostIDHeartbeater.Start()
 	r.replicatorclientFactory.SetTChannel(r.GetTChannel())
-	r.clientFactory = r.GetClientFactory()
 
 	r.metadataReconciler = NewMetadataReconciler(r.metaClient, r, r.localZone, r.logger, r.m3Client)
 	r.metadataReconciler.Start()