[GCS]Fix a bug that creates invalid connection (#11590)

Co-authored-by: 灵洵 <fengbin.ffb@antfin.com>
ray-project · Oct 27, 2020 · ebe9a88 · ebe9a88
1 parent d9f1874
commit ebe9a88
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/src/ray/gcs/gcs_server/gcs_actor_manager.cc b/src/ray/gcs/gcs_server/gcs_actor_manager.cc
@@ -952,14 +952,6 @@ void GcsActorManager::LoadInitialData(const EmptyCallback &done) {
           PollOwnerForActorOutOfScope(actor);
         }
 
-        auto &workers = owners_[actor->GetNodeID()];
-        auto it = workers.find(actor->GetWorkerID());
-        if (it == workers.end()) {
-          std::shared_ptr<rpc::CoreWorkerClientInterface> client =
-              worker_client_factory_(actor->GetOwnerAddress());
-          workers.emplace(actor->GetOwnerID(), Owner(std::move(client)));
-        }
-
         if (!actor->GetWorkerID().IsNil()) {
           RAY_CHECK(!actor->GetNodeID().IsNil());
           node_to_workers[actor->GetNodeID()].emplace_back(actor->GetWorkerID());