Skip to content

Commit cb92d5e

Browse files
authored
Merge pull request #307 from dclong/dev
Merge dev into main
2 parents 5c74ac3 + ce37520 commit cb92d5e

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

dsutil/hadoop/hdfs.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,8 @@ def du(self, path: str, depth: int = 1) -> pd.DataFrame:
8383
def _du_helper(self, path: str) -> pd.DataFrame:
8484
cmd = f"{self.bin} dfs -du {path}"
8585
logger.info("Running command: {}. Might take a while.", cmd)
86-
frame = to_frame(cmd, split=r" +", header=["size", "path"])
86+
frame = to_frame(cmd, split=r" +", header=["bytes", "path"])
87+
frame.bytes = frame.bytes.astype(int)
8788
return frame
8889

8990
def exists(self, path: str) -> bool:

0 commit comments

Comments
 (0)