From 726c4cd6d44ca10850fc4490b8fd04d0e009390a Mon Sep 17 00:00:00 2001 From: ZhuSenlin Date: Fri, 3 Jul 2020 15:48:32 +0800 Subject: [PATCH] fix actor accessor initialize inside redis gcs client (#9284) Co-authored-by: senlin.zsl --- src/ray/gcs/redis_gcs_client.cc | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/ray/gcs/redis_gcs_client.cc b/src/ray/gcs/redis_gcs_client.cc index ef5c507cf..46e2f7c79 100644 --- a/src/ray/gcs/redis_gcs_client.cc +++ b/src/ray/gcs/redis_gcs_client.cc @@ -69,7 +69,12 @@ Status RedisGcsClient::Connect(boost::asio::io_service &io_service) { actor_checkpoint_id_table_.reset(new ActorCheckpointIdTable(shard_contexts, this)); resource_table_.reset(new DynamicResourceTable({primary_context}, this)); worker_failure_table_.reset(new WorkerFailureTable(shard_contexts, this)); - actor_accessor_.reset(new RedisActorInfoAccessor(this)); + + if (RayConfig::instance().gcs_actor_service_enabled()) { + actor_accessor_.reset(new RedisActorInfoAccessor(this)); + } else { + actor_accessor_.reset(new RedisLogBasedActorInfoAccessor(this)); + } job_accessor_.reset(new RedisJobInfoAccessor(this)); object_accessor_.reset(new RedisObjectInfoAccessor(this)); node_accessor_.reset(new RedisNodeInfoAccessor(this));