from paddle.distributed.fleet.utils import HDFSClient

class MyHDFSClient(HDFSClient):
    def _run_safe_cmd(self, cmd, redirect_stderr=False, retry_times=5):
            cmdStr = " ".join(cmd)
            super()._run_safe_cmd(self, cmdStr, redirect_stderr=False, retry_times=5)