Question about Flink-SQL

[Roc Marshal]

Hello,

Does Flink-SQL support fetching Mysql meta information automaticly  in the latest version, ? If not, could the you adding this feature ?

Thank you.

Best, Roc.

 

[Leonard Xu]

Hi, Roc

Does Flink-SQL support fetching Mysql meta information automaticly  in the latest version, ? If not, could the you adding this feature ?

You can obtain the latest meta information(table schema) by using Flink JdbcCalatag[1], only PostgresCatalog is implemented, user can implemented the JdbcCalatag by themselves (e.g. MysqlCatalog), I didn’t see the plan in the latest version. 

BTW, Flink SQL does not  support table schema evolving because Flink requires the table schema is determinate in SQL job compile phase, most SQL engines also have this limitation.

Best,

Leonard

[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/jdbc.html#usage-of-postgrescatalog