Hello Flavio,
thank you for looking into the matter.
The 2nd Sequence given to RowTypeInfo has only informational value AFAICS.
It does not prevent the issue from happening, I'm afraid.
Martin
P.S.: The behavior is now reported as 'FLINK-4108'.
On Tue, Jun 21, 2016 at 12:16 PM Flavio Pomperma
Hi,
I also think this is a bug. Can you file a JIRA issue for it?
Regards,
Robert
On Tue, Jun 21, 2016 at 12:15 PM, Flavio Pompermaier
wrote:
> I think the problem is somehow related to
> val DB_ROWTYPE = new RowTypeInfo(
> Seq(BasicTypeInfo.INT_TYPE_INFO),
> Seq("id"))
>
> You have
I think the problem is somehow related to
val DB_ROWTYPE = new RowTypeInfo(
Seq(BasicTypeInfo.INT_TYPE_INFO),
Seq("id"))
You have only one filed, I think Seq("id") should be removed.
However this is a bug IMHO, this kind of error should be checked with and
handler with a proper error.
Hello everyone,
JDBCInputFormat of flink 1.1-SNAPSHOT fails with an NPE in Row.productArity:
%% snip %%
java.io.IOException: Couldn't access resultSet
at
org.apache.flink.api.java.io.jdbc.JDBCInputFormat.nextRecord(JDBCInputFormat.java:288)
at
org.apache.flink.api.java.io.jdbc.
