From 1c014e05f8429bfe15d25ff9006881b0af608d0e Mon Sep 17 00:00:00 2001 From: jovany-wang Date: Mon, 17 Jun 2019 11:54:44 +0800 Subject: [PATCH] fix --- src/ray/raylet/worker_pool.cc | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/ray/raylet/worker_pool.cc b/src/ray/raylet/worker_pool.cc index 43698c53f0d8..d4ac4cf4ecce 100644 --- a/src/ray/raylet/worker_pool.cc +++ b/src/ray/raylet/worker_pool.cc @@ -164,7 +164,10 @@ void WorkerPool::RegisterWorker(const std::shared_ptr &worker) { state.registered_workers.insert(std::move(worker)); auto it = state.starting_worker_processes.find(pid); - RAY_CHECK(it != state.starting_worker_processes.end()); + if (it == state.starting_worker_processes.end()) { + RAY_LOG(WARNING) << "Received a register request from an unknown worker " << pid; + return; + } it->second--; if (it->second == 0) { state.starting_worker_processes.erase(it);