From 2a79571c29edc825f17c5b96b3c25df0a22bcefb Mon Sep 17 00:00:00 2001 From: fangfengbin <869218239a@zju.edu.cn> Date: Thu, 24 Sep 2020 11:28:08 +0800 Subject: [PATCH] [Placement Group] Optimize log (#10974) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 灵洵 --- src/ray/raylet/node_manager.cc | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/ray/raylet/node_manager.cc b/src/ray/raylet/node_manager.cc index 394416792..e3c0730c6 100644 --- a/src/ray/raylet/node_manager.cc +++ b/src/ray/raylet/node_manager.cc @@ -1814,8 +1814,8 @@ void NodeManager::HandlePrepareBundleResources( // TODO(sang): Port this onto the new scheduler. RAY_CHECK(!new_scheduler_enabled_) << "Not implemented yet."; auto bundle_spec = BundleSpecification(request.bundle_spec()); - RAY_LOG(DEBUG) << "bundle prepare request " << bundle_spec.BundleId().first - << bundle_spec.BundleId().second; + RAY_LOG(DEBUG) << "Request to prepare bundle resources is received, " + << bundle_spec.DebugString(); auto prepared = PrepareBundle(cluster_resource_map_, bundle_spec); if (!prepared) { reply->set_success(false); @@ -1835,8 +1835,8 @@ void NodeManager::HandleCommitBundleResources( RAY_CHECK(!new_scheduler_enabled_) << "Not implemented yet."; auto bundle_spec = BundleSpecification(request.bundle_spec()); - RAY_LOG(DEBUG) << "Received bundle commit request " << bundle_spec.BundleId().first - << bundle_spec.BundleId().second; + RAY_LOG(DEBUG) << "Request to commit bundle resources is received, " + << bundle_spec.DebugString(); CommitBundle(cluster_resource_map_, bundle_spec); send_reply_callback(Status::OK(), nullptr, nullptr); @@ -1850,9 +1850,9 @@ void NodeManager::HandleCancelResourceReserve( rpc::CancelResourceReserveReply *reply, rpc::SendReplyCallback send_reply_callback) { RAY_CHECK(!new_scheduler_enabled_) << "Not implemented"; auto bundle_spec = BundleSpecification(request.bundle_spec()); - RAY_LOG(INFO) << "bundle return resource request " << bundle_spec.BundleId().first - << bundle_spec.BundleId().second; - auto resource_set = bundle_spec.GetRequiredResources(); + RAY_LOG(INFO) << "Request to cancel reserved resource is received, " + << bundle_spec.DebugString(); + const auto &resource_set = bundle_spec.GetRequiredResources(); // Kill all workers that are currently associated with the placement group. std::vector> workers_associated_with_pg;