From 20c7fad4f4426582da89765c607c487c875bc7ab Mon Sep 17 00:00:00 2001 From: Eric Liang Date: Wed, 12 Dec 2018 16:51:29 -0800 Subject: [PATCH] Move actor table to primary redis context --- src/ray/gcs/client.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/ray/gcs/client.cc b/src/ray/gcs/client.cc index c1cbee113..ba660e4f0 100644 --- a/src/ray/gcs/client.cc +++ b/src/ray/gcs/client.cc @@ -106,13 +106,13 @@ AsyncGcsClient::AsyncGcsClient(const std::string &address, int port, /*password=*/password)); } + actor_table_.reset(new ActorTable({primary_context_}, this)); client_table_.reset(new ClientTable({primary_context_}, this, client_id)); error_table_.reset(new ErrorTable({primary_context_}, this)); driver_table_.reset(new DriverTable({primary_context_}, this)); heartbeat_batch_table_.reset(new HeartbeatBatchTable({primary_context_}, this)); // Tables below would be sharded. object_table_.reset(new ObjectTable(shard_contexts_, this, command_type)); - actor_table_.reset(new ActorTable(shard_contexts_, this)); raylet_task_table_.reset(new raylet::TaskTable(shard_contexts_, this, command_type)); task_reconstruction_log_.reset(new TaskReconstructionLog(shard_contexts_, this)); task_lease_table_.reset(new TaskLeaseTable(shard_contexts_, this));