diff --git a/python/paddle/fluid/incubate/fleet/utils/hdfs.py b/python/paddle/fluid/incubate/fleet/utils/hdfs.py index 1d1714bf72d306680d0b92d2b618f66f0f62a2be..53fb92748d82c5d2d3575f8695bd2f1d4dc7832b 100644 --- a/python/paddle/fluid/incubate/fleet/utils/hdfs.py +++ b/python/paddle/fluid/incubate/fleet/utils/hdfs.py @@ -44,10 +44,10 @@ _logger = get_logger( class HDFSClient(object): """ - A tool of HDFS + A tool of HDFS Args: - hadoop_home (string): hadoop_home + hadoop_home (string): hadoop_home configs (dict): hadoop config, it is a dict, please contain \ key "fs.default.name" and "hadoop.job.ugi" Can be a float value @@ -467,7 +467,7 @@ class HDFSClient(object): self.make_local_dirs(local_path) - all_files = client.ls(hdfs_path) + all_files = self.ls(hdfs_path) procs = [] for i in range(multi_processes):