From 1048b166d9db56dafd93d714ad0bcf9fd92cfaeb Mon Sep 17 00:00:00 2001 From: Roc <30228238+sljlp@users.noreply.github.com> Date: Tue, 31 Jan 2023 15:01:47 +0800 Subject: [PATCH] fix send start msg (#50085) --- paddle/fluid/distributed/fleet_executor/carrier.cc | 1 + 1 file changed, 1 insertion(+) diff --git a/paddle/fluid/distributed/fleet_executor/carrier.cc b/paddle/fluid/distributed/fleet_executor/carrier.cc index 2b75c3ba066..4a759646067 100644 --- a/paddle/fluid/distributed/fleet_executor/carrier.cc +++ b/paddle/fluid/distributed/fleet_executor/carrier.cc @@ -179,6 +179,7 @@ void Carrier::Start() { "Using carrier before initialized.")); InterceptorMessage start_msg; start_msg.set_dst_id(SOURCE_ID); + start_msg.set_src_id(SOURCE_ID); start_msg.set_message_type(START); Send(start_msg); // TODO(wangxi): async step -- GitLab