You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2017/07/06 04:26:04 UTC
[6/6] flink git commit: [FLINK-6422] [core] Unreachable code in
FileInputFormat#createInputSplits
[FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSplits
This closes #4202.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/530a4d1f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/530a4d1f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/530a4d1f
Branch: refs/heads/release-1.3
Commit: 530a4d1f6ca7a55933563a949393046f58b23af9
Parents: 6630dfd
Author: zhangminglei <zm...@163.com>
Authored: Wed Jun 28 08:45:12 2017 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Wed Jul 5 18:10:29 2017 +0800
----------------------------------------------------------------------
.../main/java/org/apache/flink/api/common/io/FileInputFormat.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/530a4d1f/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
----------------------------------------------------------------------
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 4e81dab..1c8e7ff 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
@@ -501,8 +501,7 @@ public abstract class FileInputFormat<OT> extends RichInputFormat<OT, FileInputS
}
- final long maxSplitSize = (minNumSplits < 1) ? Long.MAX_VALUE : (totalLength / minNumSplits +
- (totalLength % minNumSplits == 0 ? 0 : 1));
+ final long maxSplitSize = totalLength / minNumSplits + (totalLength % minNumSplits == 0 ? 0 : 1);
// now that we have the files, generate the splits
int splitNum = 0;