Hi

I want load MySQL tables in Flink without need to specifying column names
and types (like what we can do in Apache Spark DataFrames).

Using the JDBCInputFormat we should pass the table fields type in the
method setRowTypeInfo. I couldn't find any way to force Flink to infer the
column type.

In addition, I was wondering if it's possible to do the same using
TableSource?

thanks

Reply via email to