Ted Yu created FLINK-6422:
-----------------------------
Summary: Unreachable code in FileInputFormat#createInputSplits
Key: FLINK-6422
URL: https://issues.apache.org/jira/browse/FLINK-6422
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
Here is related code:
{code}
if (minNumSplits < 1) {
throw new IllegalArgumentException("Number of input splits has to be at
least 1.");
}
...
final long maxSplitSize = (minNumSplits < 1) ? Long.MAX_VALUE :
(totalLength / minNumSplits +
(totalLength % minNumSplits == 0 ? 0 : 1));
{code}
minNumSplits wouldn't be less than 1 getting to the assignment of maxSplitSize.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
