diff --git a/paddle/fluid/operators/distributed/grpc_client.h b/paddle/fluid/operators/distributed/grpc_client.h index 69705d72106488015b538c0758e6af48c448164c..7a08f2d3a4a28a4323723e6b887c50588eed2bce 100644 --- a/paddle/fluid/operators/distributed/grpc_client.h +++ b/paddle/fluid/operators/distributed/grpc_client.h @@ -212,7 +212,7 @@ class GRPCClient : public RPCClient { int64_t time_out = FLAGS_rpc_deadline) override; void AsyncCheckpointNotify(const std::string& ep, const std::string& dir, - int64_t time_out = FLAGS_grpc_deadline) override; + int64_t time_out = FLAGS_rpc_deadline) override; void Wait() override; diff --git a/paddle/fluid/operators/distributed/rpc_client.h b/paddle/fluid/operators/distributed/rpc_client.h index cc3ae96787a1c29cbc3df72233aaef70d6d94e03..37783b78ecc5c58aab3e358066bd7f2fba861799 100644 --- a/paddle/fluid/operators/distributed/rpc_client.h +++ b/paddle/fluid/operators/distributed/rpc_client.h @@ -56,9 +56,9 @@ class RPCClient { virtual void AsyncSendFetchBarrier(const std::string& ep, int64_t time_out = FLAGS_rpc_deadline) = 0; - virtual void AsyncCheckpointNotify( - const std::string& ep, const std::string& dir, - int64_t time_out = FLAGS_grpc_deadline) = 0; + virtual void AsyncCheckpointNotify(const std::string& ep, + const std::string& dir, + int64_t time_out = FLAGS_rpc_deadline) = 0; // SendComplete tells all the server that current trainer have no more data // to train, so that the pserver can reduce it's barrier count, and continue