flink jdbc connector不支持source

2022-04-09 Thread casel.chen
现有一个场景是需要用flink一次性批量将某个mysql库下指定表(不同schema)同步到hudi表里面,查了一下官网flink jdbc connector [1] 文档说明只支持sink,不支持source。请问社区有支持计划吗?如果没有的话,自己要如何开发,可以给个例子吗?谢谢! [1] https://nightlies.apache.org/flink/flink-docs-release-1.13/zh/docs/connectors/datastream/jdbc/

Re: flink jdbc connector不支持source

2022-04-10 Thread Qingsheng Ren
Hi, JDBC connector 是支持 source 的,应该是没有将最新的文档同步翻译成中文,可以参考一下英文文档 [1]。 [1] https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/ 祝好 > On Apr 10, 2022, at 11:07, casel.chen wrote: > > 现有一个场景是需要用flink一次性批量将某个mysql库下指定表(不同schema)同步到hudi表里面,查了一下官网flink jdbc > connec