my_hdfs_client.py 279 B

123456
  1. from paddle.distributed.fleet.utils import HDFSClient
  2. class MyHDFSClient(HDFSClient):
  3. def _run_safe_cmd(self, cmd, redirect_stderr=False, retry_times=5):
  4. cmdStr = " ".join(cmd)
  5. super()._run_safe_cmd(self, cmdStr, redirect_stderr=False, retry_times=5)