瀏覽代碼

read hdfs

丁云鹏 5 月之前
父節點
當前提交
de27c33564
共有 1 個文件被更改,包括 3 次插入1 次删除
  1. 3 1
      recommend-model-produce/src/main/python/tools/utils/my_hdfs_client.py

+ 3 - 1
recommend-model-produce/src/main/python/tools/utils/my_hdfs_client.py

@@ -3,4 +3,6 @@ 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)
+            ret, lines = super()._run_safe_cmd(self, cmdStr, redirect_stderr=False, retry_times=5)
+            log.info("cmdStr: {} ret: {} lines: {}".format(cmdStr,ret,lines))
+            return ret, lines