diff --git a/python/ray/worker.py b/python/ray/worker.py index f7d67e008..4eca2b338 100644 --- a/python/ray/worker.py +++ b/python/ray/worker.py @@ -622,6 +622,7 @@ def init( if address: redis_address, _, _ = services.validate_redis_address(address) + print("Connecting to existing Ray cluster at address:", redis_address) else: redis_address = None diff --git a/src/ray/gcs/gcs_client/global_state_accessor.cc b/src/ray/gcs/gcs_client/global_state_accessor.cc index 260140a3e..a4d8cfa28 100644 --- a/src/ray/gcs/gcs_client/global_state_accessor.cc +++ b/src/ray/gcs/gcs_client/global_state_accessor.cc @@ -22,8 +22,8 @@ namespace gcs { GlobalStateAccessor::GlobalStateAccessor(const std::string &redis_address, const std::string &redis_password, bool is_test) { - RAY_LOG(INFO) << "Redis server address = " << redis_address - << ", is test flag = " << is_test; + RAY_LOG(DEBUG) << "Redis server address = " << redis_address + << ", is test flag = " << is_test; std::vector address; boost::split(address, redis_address, boost::is_any_of(":")); RAY_CHECK(address.size() == 2); diff --git a/src/ray/gcs/gcs_client/service_based_accessor.cc b/src/ray/gcs/gcs_client/service_based_accessor.cc index 3682a367c..a0123f136 100644 --- a/src/ray/gcs/gcs_client/service_based_accessor.cc +++ b/src/ray/gcs/gcs_client/service_based_accessor.cc @@ -89,7 +89,7 @@ Status ServiceBasedJobInfoAccessor::AsyncSubscribeAll( } void ServiceBasedJobInfoAccessor::AsyncResubscribe(bool is_pubsub_server_restarted) { - RAY_LOG(INFO) << "Reestablishing subscription for job info."; + RAY_LOG(DEBUG) << "Reestablishing subscription for job info."; // If only the GCS sever has restarted, we only need to fetch data from the GCS server. // If the pub-sub server has also restarted, we need to resubscribe to the pub-sub // server first, then fetch data from the GCS server. @@ -419,7 +419,7 @@ Status ServiceBasedActorInfoAccessor::AsyncGetCheckpointID( } void ServiceBasedActorInfoAccessor::AsyncResubscribe(bool is_pubsub_server_restarted) { - RAY_LOG(INFO) << "Reestablishing subscription for actor info."; + RAY_LOG(DEBUG) << "Reestablishing subscription for actor info."; // If only the GCS sever has restarted, we only need to fetch data from the GCS server. // If the pub-sub server has also restarted, we need to resubscribe to the pub-sub // server first, then fetch data from the GCS server. @@ -805,7 +805,7 @@ void ServiceBasedNodeInfoAccessor::HandleNotification(const GcsNodeInfo &node_in } void ServiceBasedNodeInfoAccessor::AsyncResubscribe(bool is_pubsub_server_restarted) { - RAY_LOG(INFO) << "Reestablishing subscription for node info."; + RAY_LOG(DEBUG) << "Reestablishing subscription for node info."; // If only the GCS sever has restarted, we only need to fetch data from the GCS server. // If the pub-sub server has also restarted, we need to resubscribe to the pub-sub // server first, then fetch data from the GCS server. @@ -1081,7 +1081,7 @@ Status ServiceBasedTaskInfoAccessor::AttemptTaskReconstruction( } void ServiceBasedTaskInfoAccessor::AsyncResubscribe(bool is_pubsub_server_restarted) { - RAY_LOG(INFO) << "Reestablishing subscription for task info."; + RAY_LOG(DEBUG) << "Reestablishing subscription for task info."; // If only the GCS sever has restarted, we only need to fetch data from the GCS server. // If the pub-sub server has also restarted, we need to resubscribe to the pub-sub // server first, then fetch data from the GCS server. @@ -1256,7 +1256,7 @@ Status ServiceBasedObjectInfoAccessor::AsyncSubscribeToLocations( } void ServiceBasedObjectInfoAccessor::AsyncResubscribe(bool is_pubsub_server_restarted) { - RAY_LOG(INFO) << "Reestablishing subscription for object locations."; + RAY_LOG(DEBUG) << "Reestablishing subscription for object locations."; // If only the GCS sever has restarted, we only need to fetch data from the GCS server. // If the pub-sub server has also restarted, we need to resubscribe to the pub-sub // server first, then fetch data from the GCS server. @@ -1367,7 +1367,7 @@ Status ServiceBasedWorkerInfoAccessor::AsyncSubscribeToWorkerFailures( } void ServiceBasedWorkerInfoAccessor::AsyncResubscribe(bool is_pubsub_server_restarted) { - RAY_LOG(INFO) << "Reestablishing subscription for worker failures."; + RAY_LOG(DEBUG) << "Reestablishing subscription for worker failures."; // If the pub-sub server has restarted, we need to resubscribe to the pub-sub server. if (subscribe_operation_ != nullptr && is_pubsub_server_restarted) { RAY_CHECK_OK(subscribe_operation_(nullptr)); diff --git a/src/ray/gcs/gcs_client/service_based_gcs_client.cc b/src/ray/gcs/gcs_client/service_based_gcs_client.cc index d2f5e1a50..552058f61 100644 --- a/src/ray/gcs/gcs_client/service_based_gcs_client.cc +++ b/src/ray/gcs/gcs_client/service_based_gcs_client.cc @@ -83,7 +83,7 @@ Status ServiceBasedGcsClient::Connect(boost::asio::io_service &io_service) { is_connected_ = true; - RAY_LOG(INFO) << "ServiceBasedGcsClient Connected."; + RAY_LOG(DEBUG) << "ServiceBasedGcsClient connected."; return Status::OK(); } @@ -192,8 +192,8 @@ void ServiceBasedGcsClient::ReconnectGcsServer() { RAY_LOG(DEBUG) << "Attemptting to reconnect to GCS server: " << address.first << ":" << address.second; if (Ping(address.first, address.second, 100)) { - RAY_LOG(INFO) << "Reconnected to GCS server: " << address.first << ":" - << address.second; + RAY_LOG(DEBUG) << "Reconnected to GCS server: " << address.first << ":" + << address.second; break; } } diff --git a/src/ray/gcs/redis_client.cc b/src/ray/gcs/redis_client.cc index 472ca4ea4..8c6533ccd 100644 --- a/src/ray/gcs/redis_client.cc +++ b/src/ray/gcs/redis_client.cc @@ -143,7 +143,7 @@ Status RedisClient::Connect(std::vector io_services) Attach(); is_connected_ = true; - RAY_LOG(INFO) << "RedisClient connected."; + RAY_LOG(DEBUG) << "RedisClient connected."; return Status::OK(); } diff --git a/src/ray/gcs/redis_gcs_client.cc b/src/ray/gcs/redis_gcs_client.cc index a2f07e7bb..aa71d847a 100644 --- a/src/ray/gcs/redis_gcs_client.cc +++ b/src/ray/gcs/redis_gcs_client.cc @@ -81,7 +81,7 @@ Status RedisGcsClient::Connect(boost::asio::io_service &io_service) { is_connected_ = true; - RAY_LOG(INFO) << "RedisGcsClient Connected."; + RAY_LOG(DEBUG) << "RedisGcsClient connected."; return Status::OK(); }