From b08765a08b3060c9d45e14406814f3537bd812c2 Mon Sep 17 00:00:00 2001 From: Qing Wang Date: Mon, 17 Jun 2019 13:34:23 +0800 Subject: [PATCH] Fix a crash when unknown worker registering to raylet (#4992) --- 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 43698c53f..d4ac4cf4e 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);