From e0a2b1fc8fad56bd9d791c5bc9dad3f58cf03121 Mon Sep 17 00:00:00 2001 From: Yi Cheng <74173148+iycheng@users.noreply.github.com> Date: Sat, 8 Apr 2023 03:19:55 +0000 Subject: [PATCH] fix Signed-off-by: Yi Cheng <74173148+iycheng@users.noreply.github.com> --- src/ray/raylet/node_manager.cc | 8 -------- 1 file changed, 8 deletions(-) diff --git a/src/ray/raylet/node_manager.cc b/src/ray/raylet/node_manager.cc index a8b8a1a7ddd9..e401a23e3ce8 100644 --- a/src/ray/raylet/node_manager.cc +++ b/src/ray/raylet/node_manager.cc @@ -1905,10 +1905,6 @@ void NodeManager::HandleCommitBundleResources( RAY_LOG(DEBUG) << "Request to commit resources for bundles: " << GetDebugStringForBundles(bundle_specs); placement_group_resource_manager_->CommitBundles(bundle_specs); - if (RayConfig::instance().use_ray_syncer()) { - // To reduce the lag, we trigger a broadcasting immediately. - RAY_CHECK(ray_syncer_.OnDemandBroadcasting(syncer::MessageType::RESOURCE_VIEW)); - } send_reply_callback(Status::OK(), nullptr, nullptr); cluster_task_manager_->ScheduleAndDispatchTasks(); @@ -1949,10 +1945,6 @@ void NodeManager::HandleCancelResourceReserve( // Return bundle resources. placement_group_resource_manager_->ReturnBundle(bundle_spec); - if (RayConfig::instance().use_ray_syncer()) { - // To reduce the lag, we trigger a broadcasting immediately. - RAY_CHECK(ray_syncer_.OnDemandBroadcasting(syncer::MessageType::RESOURCE_VIEW)); - } cluster_task_manager_->ScheduleAndDispatchTasks(); send_reply_callback(Status::OK(), nullptr, nullptr); }