Re: How to declare the Row object schema

2020-01-17 Thread Fabian Hueske
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 th

How to declare the Row object schema

2020-01-16 Thread 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