From f2891ab857e00bc70eb025bb430f46f4f58355a5 Mon Sep 17 00:00:00 2001
From: Maximilian Michels <mxm@apache.org>
Date: Tue, 26 May 2015 17:32:06 +0200
Subject: [PATCH] [bugfix] fix FileInputFormat for exclusively two level deep
 nested files

---
 .../java/org/apache/flink/api/common/io/FileInputFormat.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
index 61837781c7b..efa5631c0e7 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
@@ -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.");
-- 
GitLab