回复：flinksql有计划支持mysql catalog吗？

[Roc Marshal <fl...@126.com>]

旭晨，你好。
目前这个feature已经在工作中。
欢迎 review / 讨论/改进。 https://github.com/apache/flink/pull/16962

祝好。
Roc.



发自 网易邮箱大师




---- 回复的原邮件 ----
| 发件人 | 赵旭晨<jj...@163.com> |
| 日期 | 2021年10月12日 10:17 |
| 收件人 | user-zh@flink.apache.org<us...@flink.apache.org> |
| 抄送至 | |
| 主题 | flinksql有计划支持mysql catalog吗？ |
目前flink的jdbccatalog只支持PG，有计划支持mysql的吗？由于公司的元数据存储统一用mysql，不太可能再引进PG，或者反过来问，flink社区到目前为止不支持mysqlcatalog的原因是什么？有什么顾虑么？

Re:Re:回复：flinksql有计划支持mysql catalog吗？

[Yuepeng Pan <fl...@126.com>]

旭晨,你好。
关于你描述的问题，当前的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，"赵旭晨" <jj...@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" <fl...@126.com> 写道：
>>旭晨，你好。
>>目前这个feature已经在工作中。
>>欢迎 review / 讨论/改进。 https://github.com/apache/flink/pull/16962
>>
>>祝好。
>>Roc.
>>
>>
>>
>>发自 网易邮箱大师
>>
>>
>>
>>
>>---- 回复的原邮件 ----
>>| 发件人 | 赵旭晨<jj...@163.com> |
>>| 日期 | 2021年10月12日 10:17 |
>>| 收件人 | user-zh@flink.apache.org<us...@flink.apache.org> |
>>| 抄送至 | |
>>| 主题 | flinksql有计划支持mysql catalog吗？ |
>>目前flink的jdbccatalog只支持PG，有计划支持mysql的吗？由于公司的元数据存储统一用mysql，不太可能再引进PG，或者反过来问，flink社区到目前为止不支持mysqlcatalog的原因是什么？有什么顾虑么？

Re:回复：flinksql有计划支持mysql catalog吗？

[赵旭晨 <jj...@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" <fl...@126.com> 写道：
>旭晨，你好。
>目前这个feature已经在工作中。
>欢迎 review / 讨论/改进。 https://github.com/apache/flink/pull/16962
>
>祝好。
>Roc.
>
>
>
>发自 网易邮箱大师
>
>
>
>
>---- 回复的原邮件 ----
>| 发件人 | 赵旭晨<jj...@163.com> |
>| 日期 | 2021年10月12日 10:17 |
>| 收件人 | user-zh@flink.apache.org<us...@flink.apache.org> |
>| 抄送至 | |
>| 主题 | flinksql有计划支持mysql catalog吗？ |
>目前flink的jdbccatalog只支持PG，有计划支持mysql的吗？由于公司的元数据存储统一用mysql，不太可能再引进PG，或者反过来问，flink社区到目前为止不支持mysqlcatalog的原因是什么？有什么顾虑么？