fix hdfs bug

7 years ago · 5d3ecbfdf5
parent 2c1e986f22
commit 5d3ecbfdf5
1 changed files with 2 additions and 1 deletions
--- a/python/paddle/fluid/contrib/utils/hdfs_utils.py
+++ b/python/paddle/fluid/contrib/utils/hdfs_utils.py
@ -52,9 +52,10 @@ class HDFSClient(object):
        ret_code = 0
        ret_out = None
        ret_err = None
+        whole_commands = " ".join(whole_commands)
        for x in range(retry_times + 1):
            proc = subprocess.Popen(
-                whole_commands, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+                whole_commands, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
            (output, errors) = proc.communicate()
            ret_code, ret_out, ret_err = proc.returncode, output, errors
            if ret_code: