fix send start msg (#50085)

1048b166 · Roc · GitHub · 9a4acfee · 1048b166
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

paddle/fluid/distributed/fleet_executor/carrier.cc paddle/fluid/distributed/fleet_executor/carrier.cc +1 -0

未找到文件。
--- 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