Throttle object pull logs (#28952)

ray-project · Oct 1, 2022 · 8313fe8 · 8313fe8
1 parent 3f6a176
commit 8313fe8
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/ray/object_manager/object_manager.cc b/src/ray/object_manager/object_manager.cc
@@ -284,16 +284,17 @@ void ObjectManager::SendPullRequest(const ObjectID &object_id, const NodeID &cli
               pull_request,
               [object_id, client_id](const Status &status, const rpc::PullReply &reply) {
                 if (!status.ok()) {
-                  RAY_LOG(WARNING) << "Send pull " << object_id << " request to client "
-                                   << client_id << " failed due to" << status.message();
+                  RAY_LOG_EVERY_N_OR_DEBUG(INFO, 100)
+                      << "Send pull " << object_id << " request to client " << client_id
+                      << " failed due to" << status.message();
                 }
               });
         },
         "ObjectManager.SendPull");
   } else {
-    RAY_LOG(ERROR) << "Couldn't send pull request from " << self_node_id_ << " to "
-                   << client_id << " of object " << object_id
-                   << " , setup rpc connection failed.";
+    RAY_LOG_EVERY_N_OR_DEBUG(INFO, 100)
+        << "Couldn't send pull request from " << self_node_id_ << " to " << client_id
+        << " of object " << object_id << " , setup rpc connection failed.";
   }
 }