fix bug of communicator flag, test=develop (#19635)

6 years ago · f45cb1c2ca
parent 3abe84500e
commit f45cb1c2ca
1 changed files with 1 additions and 1 deletions
--- a/paddle/fluid/operators/distributed/communicator.cc
+++ b/paddle/fluid/operators/distributed/communicator.cc
@ -181,7 +181,7 @@ void Communicator::SendThread() {
 }
 void Communicator::RecvNonIndependent() {
-  if (!FLAGS_communicator_independent_recv_thread) {
+  if (FLAGS_communicator_independent_recv_thread) {
    return;
  }