Skip to content

Commit b08765a

Browse files
jovany-wangraulchen
authored andcommitted
Fix a crash when unknown worker registering to raylet (#4992)
1 parent 05e2748 commit b08765a

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/ray/raylet/worker_pool.cc

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,10 @@ void WorkerPool::RegisterWorker(const std::shared_ptr<Worker> &worker) {
164164
state.registered_workers.insert(std::move(worker));
165165

166166
auto it = state.starting_worker_processes.find(pid);
167-
RAY_CHECK(it != state.starting_worker_processes.end());
167+
if (it == state.starting_worker_processes.end()) {
168+
RAY_LOG(WARNING) << "Received a register request from an unknown worker " << pid;
169+
return;
170+
}
168171
it->second--;
169172
if (it->second == 0) {
170173
state.starting_worker_processes.erase(it);

0 commit comments

Comments
 (0)