From ebe9a8865c4527681507f46b940b261c48666cde Mon Sep 17 00:00:00 2001 From: fangfengbin <869218239a@zju.edu.cn> Date: Wed, 28 Oct 2020 01:08:06 +0800 Subject: [PATCH] [GCS]Fix a bug that creates invalid connection (#11590) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 灵洵 --- src/ray/gcs/gcs_server/gcs_actor_manager.cc | 8 -------- 1 file changed, 8 deletions(-) diff --git a/src/ray/gcs/gcs_server/gcs_actor_manager.cc b/src/ray/gcs/gcs_server/gcs_actor_manager.cc index d65ae6b89..b0205c565 100644 --- 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 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());