Skip to content

Commit

Permalink
up
Browse files Browse the repository at this point in the history
Signed-off-by: Jiajun Yao <jeromeyjj@gmail.com>
  • Loading branch information
jjyao committed Sep 26, 2024
1 parent 052d920 commit f2efd56
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/ray/common/ray_syncer/ray_syncer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -354,6 +354,7 @@ ServerBidiReactor *RaySyncerService::StartSync(grpc::CallbackServerContext *cont
[this](const std::string &node_id, bool reconnect) mutable {
// No need to reconnect for server side.
RAY_CHECK(!reconnect);
RAY_LOG(INFO) << "Connection is broken." << NodeID::FromBinary(node_id);
syncer_.sync_reactors_.erase(node_id);
syncer_.node_state_->RemoveNode(node_id);
});
Expand Down

0 comments on commit f2efd56

Please sign in to comment.