Skip to content

Commit ac87d4e

Browse files
authored
fix hdfs.download, test=develop (#20907)
1 parent 59bcdc8 commit ac87d4e

File tree

1 file changed

+3
-3
lines changed
  • python/paddle/fluid/incubate/fleet/utils

1 file changed

+3
-3
lines changed

python/paddle/fluid/incubate/fleet/utils/hdfs.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -44,10 +44,10 @@ def get_logger(name, level, fmt):
4444

4545
class HDFSClient(object):
4646
"""
47-
A tool of HDFS
47+
A tool of HDFS
4848
4949
Args:
50-
hadoop_home (string): hadoop_home
50+
hadoop_home (string): hadoop_home
5151
configs (dict): hadoop config, it is a dict, please contain \
5252
key "fs.default.name" and "hadoop.job.ugi"
5353
Can be a float value
@@ -467,7 +467,7 @@ def __subprocess_download(local_path, datas):
467467

468468
self.make_local_dirs(local_path)
469469

470-
all_files = client.ls(hdfs_path)
470+
all_files = self.ls(hdfs_path)
471471

472472
procs = []
473473
for i in range(multi_processes):

0 commit comments

Comments
 (0)