From a998c0776b1baacf69dbca3874f11a0bab4bc7c7 Mon Sep 17 00:00:00 2001
From: kuizhiqing <kuizhiqing@baidu.com>
Date: Tue, 18 Jan 2022 17:20:41 +0800
Subject: [PATCH] fix http gloo bug (#39017)

---
 python/paddle/distributed/fleet/base/role_maker.py    | 4 ----
 python/paddle/fluid/incubate/fleet/base/role_maker.py | 5 -----
 2 files changed, 9 deletions(-)

diff --git a/python/paddle/distributed/fleet/base/role_maker.py b/python/paddle/distributed/fleet/base/role_maker.py
index a77f52d788f..b08753066ca 100644
--- a/python/paddle/distributed/fleet/base/role_maker.py
+++ b/python/paddle/distributed/fleet/base/role_maker.py
@@ -224,10 +224,6 @@ class Gloo(object):
             self._worker_comm = gloo
         # TODO (sandyhouse): initialize gloo for server and all
 
-        if start_http_server:
-            http_server_d["running"] = False
-            http_server.join()
-
     def _get_rank_nodes(self, role):
         nodes = 0
         rank = -1
diff --git a/python/paddle/fluid/incubate/fleet/base/role_maker.py b/python/paddle/fluid/incubate/fleet/base/role_maker.py
index 77f9ab33c4c..3761a5a4a4a 100644
--- a/python/paddle/fluid/incubate/fleet/base/role_maker.py
+++ b/python/paddle/fluid/incubate/fleet/base/role_maker.py
@@ -734,11 +734,6 @@ class GeneralRoleMaker(RoleMakerBase):
             self._rank = all_list.index(self._cur_endpoint)
             self._size = len(all_list)
             self._worker_endpoints = worker_endpoints
-            if self._http_server is not None:
-                # set running status to False
-                self._http_server_d["running"] = False
-                # wait until child process exits
-                self._http_server.join()
             self._role_is_generated = True
 
     def all_gather(self, input):
-- 
GitLab