提交 6eae45ea 编写于 作者: Z zhangminglei 提交者: Tzu-Li (Gordon) Tai

[FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSplits

This closes #4202.
上级 21ec86f0
......@@ -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;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册