wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-03 18:57:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix streaming compile bug (#7577)

Browse Source 
Co-authored-by: 灵洵 <fengbin.ffb@antfin.com>
This commit is contained in:
fangfengbin
2020-03-12 17:26:45 +08:00
committed by GitHub
parent f5d12a958b
commit 428fb79b27
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
streaming/src/test/mock_actor.cc
+1 -1
View File
@@ -405,7 +405,7 @@ class StreamingWorker {
STREAMING_LOG(INFO) << "Init message: " << message->ToString();
std::string actor_handle_serialized = message->ActorHandleSerialized();
worker_->DeserializeAndRegisterActorHandle(actor_handle_serialized);
worker_->DeserializeAndRegisterActorHandle(actor_handle_serialized, ObjectID::Nil());
std::shared_ptr<ActorHandle> actor_handle(new ActorHandle(actor_handle_serialized));
STREAMING_CHECK(actor_handle != nullptr);
STREAMING_LOG(INFO) << " actor id from handle: " << actor_handle->GetActorID();
streaming/src/test/queue_tests_base.h
+3 -1
View File
@@ -154,7 +154,9 @@ class StreamingQueueTestBase : public ::testing::TestWithParam<uint64_t> {
const std::vector<ObjectID> &rescale_queue_ids, std::string suite_name,
std::string test_name, uint64_t param) {
std::string forked_serialized_str;
Status st = driver.SerializeActorHandle(peer_actor_id, &forked_serialized_str);
ObjectID actor_handle_id;
Status st = driver.SerializeActorHandle(peer_actor_id, &forked_serialized_str,
&actor_handle_id);
STREAMING_CHECK(st.ok());
STREAMING_LOG(INFO) << "forked_serialized_str: " << forked_serialized_str;
TestInitMessage msg(role, self_actor_id, peer_actor_id, forked_serialized_str,