diff --git a/paddle/fluid/distributed/fleet_executor/interceptor.cc b/paddle/fluid/distributed/fleet_executor/interceptor.cc index 108b6e516f9178..40429502825c9c 100644 --- a/paddle/fluid/distributed/fleet_executor/interceptor.cc +++ b/paddle/fluid/distributed/fleet_executor/interceptor.cc @@ -51,8 +51,7 @@ void Interceptor::Handle(const InterceptorMessage& msg) { InterceptorMessage msg; msg.set_message_type(STOP); Send(interceptor_id_, msg); - } - if (msg.message_type() == STOP) { + } else if (msg.message_type() == STOP) { stop_ = true; StopCarrier(); }