How to declare the Row object schema

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

How to declare the Row object schema

Soheil Pourbafrani
Hi,

Inserting a DataSet of the type Row using the Flink JDBCOutputFormat I continuously go the warning:
[DataSink (org.apache.flink.api.java.io.jdbc.JDBCOutputFormat@18be83e4) (1/4)] WARN org.apache.flink.api.java.io.jdbc.JDBCOutputFormat - Unknown column type for column 8. Best effort approach to set its value: system.

I tried to declare the Row schema by implementing the ResultTypeQueryable class alongside with the FlatMap function I create the final Row type for insertion but made no changes!

What is this warning for?
Reply | Threaded
Open this post in threaded view
|

Re: How to declare the Row object schema

Fabian Hueske-2
Hi,

Which version are you using?
I can't find the error message in the current code base.

When writing data to a JDBC database, all Flink types must be correctly matched to a JDBC type.
The problem is probably that Flink cannot match the 8th field of your Row to a JDBC type.
What's the type of the 8th field?

Best, Fabian

Am Do., 16. Jan. 2020 um 20:51 Uhr schrieb Soheil Pourbafrani <[hidden email]>:
Hi,

Inserting a DataSet of the type Row using the Flink JDBCOutputFormat I continuously go the warning:
[DataSink (org.apache.flink.api.java.io.jdbc.JDBCOutputFormat@18be83e4) (1/4)] WARN org.apache.flink.api.java.io.jdbc.JDBCOutputFormat - Unknown column type for column 8. Best effort approach to set its value: system.

I tried to declare the Row schema by implementing the ResultTypeQueryable class alongside with the FlatMap function I create the final Row type for insertion but made no changes!

What is this warning for?