From c84fd80399c8023a1063898a6ea316e0059acd83 Mon Sep 17 00:00:00 2001 From: Ruiyang Wang Date: Wed, 18 Sep 2024 14:30:59 -0700 Subject: [PATCH] move gcs_table_storage_ back to main service. Signed-off-by: Ruiyang Wang --- src/ray/gcs/gcs_server/gcs_server.cc | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/ray/gcs/gcs_server/gcs_server.cc b/src/ray/gcs/gcs_server/gcs_server.cc index f9601fcae7f8c..08de01b8862a4 100644 --- a/src/ray/gcs/gcs_server/gcs_server.cc +++ b/src/ray/gcs/gcs_server/gcs_server.cc @@ -73,16 +73,16 @@ GcsServer::GcsServer(const ray::gcs::GcsServerConfig &config, periodical_runner_(main_service), is_started_(false), is_stopped_(false) { - // Init GCS table storage. + // Init GCS table storage. Note this is on main_service_, not kv_io_context_, to avoid + // congestion on the kv_io_context_. RAY_LOG(INFO) << "GCS storage type is " << storage_type_; switch (storage_type_) { case StorageType::IN_MEMORY: - gcs_table_storage_ = - std::make_shared(kv_io_context_.GetIoService()); + gcs_table_storage_ = std::make_shared(main_service_); break; case StorageType::REDIS_PERSIST: - gcs_table_storage_ = std::make_shared( - GetOrConnectRedis(kv_io_context_.GetIoService())); + gcs_table_storage_ = + std::make_shared(GetOrConnectRedis(main_service_)); break; default: RAY_LOG(FATAL) << "Unexpected storage type: " << storage_type_;