[
https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071527#comment-16071527
]
ASF GitHub Bot commented on FLINK-6422:
---------------------------------------
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4202
Seems I could not get any useful information from CI, except for this kinda
stuff following and it seems not relevant to this issue.
```
Running org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase
java.lang.RuntimeException: org.apache.zookeeper.server.ZooKeeperServer
class is frozen
at javassist.CtClassType.checkModify(CtClassType.java:288)
at javassist.CtBehavior.setBody(CtBehavior.java:432)
at javassist.CtBehavior.setBody(CtBehavior.java:412)
at
org.apache.curator.test.ByteCodeRewrite.fixMethods(ByteCodeRewrite.java:91)
at
org.apache.curator.test.ByteCodeRewrite.<clinit>(ByteCodeRewrite.java:50)
at org.apache.curator.test.TestingServer.<clinit>(TestingServer.java:33)
at
org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.testCheckpointedStreamingProgram(JobManagerHACheckpointRecoveryITCase.java:345)
at
org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.testCheckpointedStreamingProgramIncrementalRocksDB(JobManagerHACheckpointRecoveryITCase.java:331)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
```
> Unreachable code in FileInputFormat#createInputSplits
> -----------------------------------------------------
>
> Key: FLINK-6422
> URL: https://issues.apache.org/jira/browse/FLINK-6422
> Project: Flink
> Issue Type: Bug
> Components: Batch Connectors and Input/Output Formats
> Reporter: Ted Yu
> Assignee: mingleizhang
> 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.4.14#64029)
