[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960447#comment-15960447
]
ASF GitHub Bot commented on FLINK-6271:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3686#discussion_r110337050
--- Diff:
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java
---
@@ -162,11 +162,11 @@ public void
testJDBCInputFormatWithParallelismAndNumericColumnSplitting() throws
if (next == null) {
break;
}
- if(next.getField(0)!=null) {
Assert.assertEquals("Field 0 should be int", Integer.class,
next.getField(0).getClass());}
- if(next.getField(1)!=null) {
Assert.assertEquals("Field 1 should be String", String.class,
next.getField(1).getClass());}
- if(next.getField(2)!=null) {
Assert.assertEquals("Field 2 should be String", String.class,
next.getField(2).getClass());}
- if(next.getField(3)!=null) {
Assert.assertEquals("Field 3 should be float", Double.class,
next.getField(3).getClass());}
- if(next.getField(4)!=null) {
Assert.assertEquals("Field 4 should be int", Integer.class,
next.getField(4).getClass());}
+ if (next.getField(0) != null) {
Assert.assertEquals("Field 0 should be int", Integer.class,
next.getField(0).getClass());}
--- End diff --
you missed putting the assertions on a new line.
> NumericBetweenParametersProvider NullPointer
> --------------------------------------------
>
> Key: FLINK-6271
> URL: https://issues.apache.org/jira/browse/FLINK-6271
> Project: Flink
> Issue Type: Bug
> Components: Batch Connectors and Input/Output Formats
> Affects Versions: 1.2.0
> Reporter: Flavio Pompermaier
> Assignee: Flavio Pompermaier
> Labels: jdbc
>
> creating a NumericBetweenParametersProvider using fetchSize=1000, min=0 and
> max= 999 fails with a NP
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)