From 620999c917fa6e948d238a80ea9c774e72b28dbb Mon Sep 17 00:00:00 2001 From: tangwei12 Date: Thu, 21 Jun 2018 15:44:39 +0800 Subject: [PATCH] save checkpoint bug fix --- paddle/fluid/operators/checkpoint_notify_op.cc | 4 ++-- paddle/fluid/operators/listen_and_serv_op.cc | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/paddle/fluid/operators/checkpoint_notify_op.cc b/paddle/fluid/operators/checkpoint_notify_op.cc index 31b725ec1..e7a65b76a 100644 --- a/paddle/fluid/operators/checkpoint_notify_op.cc +++ b/paddle/fluid/operators/checkpoint_notify_op.cc @@ -39,8 +39,8 @@ class CheckpointNotifyOp : public framework::OperatorBase { std::string dir = Attr("dir"); std::string lookup_table_name = Attr("lookup_table"); - detail::RPCClient* rpc_client = - detail::RPCClient::GetInstance(); + distributed::RPCClient* rpc_client = + distributed::RPCClient::GetInstance(); for (size_t i = 0; i < epmap.size(); i++) { VLOG(3) << "checkpoint notify sending " << dir << " to " << epmap[i]; auto serial_looku_table = diff --git a/paddle/fluid/operators/listen_and_serv_op.cc b/paddle/fluid/operators/listen_and_serv_op.cc index 420c4e9e4..df9cdae97 100644 --- a/paddle/fluid/operators/listen_and_serv_op.cc +++ b/paddle/fluid/operators/listen_and_serv_op.cc @@ -268,7 +268,7 @@ void ListenAndServOp::RunImpl(const framework::Scope &scope, request_get_handler_.get()); rpc_service_->RegisterRPC(distributed::kRequestPrefetch, request_prefetch_handler_.get()); - rpc_service_->RegisterRPC(detail::kRequestCheckpoint, + rpc_service_->RegisterRPC(distributed::kRequestCheckpoint, request_checkpoint_handler_.get()); auto *optimize_block = Attr(kOptimizeBlock); -- GitLab