diff --git a/python/paddle/distributed/fleet/elastic/collective.py b/python/paddle/distributed/fleet/elastic/collective.py index 82055314b0dc8c7820f159fb641e17b37a50b42e..de350e15d35c02e17af42ef4467c543538dafaae 100644 --- a/python/paddle/distributed/fleet/elastic/collective.py +++ b/python/paddle/distributed/fleet/elastic/collective.py @@ -31,9 +31,9 @@ class CollectiveLauncher(LauncherInterface): logger.info("collective lauchner launch ...") args = self.args self.tmp_dir = tempfile.mkdtemp() + cluster, pod = paddle.distributed.fleet.launch.get_cluster_info(args) global_envs = paddle.distributed.fleet.launch.get_global_envs( args, self.tmp_dir) - cluster, pod = paddle.distributed.fleet.launch.get_cluster_info(args) self.procs = start_local_trainers( cluster,