旭晨,你好。 关于你描述的问题,当前的MySQLCatalog的实现是不支持的,如果需要此功能,则需要重写对应的方法。https://github.com/apache/flink/pull/16962 中 twalthr 老师与 jark 老师提及后续会重构这一部分。你可以在对应的JIRA或者PR上直接进行留言做进一步的讨论。 目前基于AbstractJdbcCatalog实现的XXXCatalog, 包括PostgresCatalog和正在实现的MySQLCatalog都是不支持创建和更改表的。GenericInMemoryCatalog与HiveCatalog是支持的。
祝好, Roc. 在 2021-10-13 16:42:16,"赵旭晨" <jjrr...@163.com> 写道: >@Roc Marshal 你好: > 我大致翻了下你的FLINK-15352分支上的关于mysqlcatalog的测试代码,想问一个问题: > 目前的mysql实现,tabelenvironment通过jdbc驱动,去加载mysql元数据,那么,反过来,通过flink java > api或者sqlclient,执行DDL建表语句create > catalog.database.table,将元数据写入mysql,之后当我第二次要调用相关表的时候就不需要再建表了,因为mysql已经有相关元数据了,这个能支持吗? > > > > > > > > > > > > > > > > > >在 2021-10-12 12:06:03,"Roc Marshal" <flin...@126.com> 写道: >>旭晨,你好。 >>目前这个feature已经在工作中。 >>欢迎 review / 讨论/改进。 https://github.com/apache/flink/pull/16962 >> >>祝好。 >>Roc. >> >> >> >>发自 网易邮箱大师 >> >> >> >> >>---- 回复的原邮件 ---- >>| 发件人 | 赵旭晨<jjrr...@163.com> | >>| 日期 | 2021年10月12日 10:17 | >>| 收件人 | user-zh@flink.apache.org<user-zh@flink.apache.org> | >>| 抄送至 | | >>| 主题 | flinksql有计划支持mysql catalog吗? | >>目前flink的jdbccatalog只支持PG,有计划支持mysql的吗?由于公司的元数据存储统一用mysql,不太可能再引进PG,或者反过来问,flink社区到目前为止不支持mysqlcatalog的原因是什么?有什么顾虑么?