提交 f2891ab8 编写于 作者: M Maximilian Michels

[bugfix] fix FileInputFormat for exclusively two level deep nested files

上级 baeedba5
......@@ -543,7 +543,7 @@ public abstract class FileInputFormat<OT> implements InputFormat<OT, FileInputSp
for(FileStatus dir: fs.listStatus(path)) {
if (dir.isDir()) {
if (acceptFile(dir)) {
addNestedFiles(dir.getPath(), files, length, logExcludedFiles);
length += addNestedFiles(dir.getPath(), files, length, logExcludedFiles);
} else {
if (logExcludedFiles && LOG.isDebugEnabled()) {
LOG.debug("Directory "+dir.getPath().toString()+" did not pass the file-filter and is excluded.");
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册