wassname/ray
1
0 Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-10-01 12:31:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix actor accessor initialize inside redis gcs client (#9284)

Browse Source 
Co-authored-by: senlin.zsl <senlin.zsl@antfin.com>
This commit is contained in:
ZhuSenlinandsenlin.zsl authored and GitHub committed 2020-07-03 15:48:32 +08:00
1 parent 65f89753b0
commit 726c4cd6d4
1 file changed
+6 -1
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/redis_gcs_client.cc
+6 -1
View File
@@ -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));