Re: Re:RE: RE: flink cdc动态加表不生效
Hi, casel chan, 社区已经对增量框架实现动态加表(https://github.com/apache/flink-cdc/pull/3024 ),预计3.1对mongodb和postgres暴露出来,但是Oracle和Sqlserver目前并没暴露,你可以去社区参照这两个框架,将参数打开,并且测试和适配。 Best, Hongshun
RE: Re:RE: RE: flink cdc动态加表不生效
Hi, oracle cdc connector 已经接入增量快照读框架,动态加表也是可以统一去实现的。 可以去社区创建issue,也欢迎直接贡献。 Best, Jiabao On 2024/01/19 04:46:21 "casel.chen" wrote: > > > > > > > 想知道oracle cdc connector不支持动态加表的原因是什么?可否自己扩展实现呢? > > > > > > > > > > > > 在 2024-01-19 11:53:49,"Jiabao Sun" 写道: > >Hi, > > > >Oracle CDC connector[1] 目前是不支持动态加表的。 > > > >Best, > >Jiabao > > > >[1] > >https://ververica.github.io/flink-cdc-connectors/release-2.4/content/connectors/oracle-cdc.html > > > > > >On 2024/01/19 03:37:41 Jiabao Sun wrote: > >> Hi, > >> > >> 请提供一下 flink cdc 的版本,使用的什么连接器。 > >> 如果方便的话,也请提供一下日志。 > >> 另外,table 的正则表达式可以匹配到新增的表吗? > >> > >> Best, > >> Jiabao > >> > >> [1] > >> https://ververica.github.io/flink-cdc-connectors/release-3.0/content/connectors/mysql-cdc%28ZH%29.html#id15 > >> > >> On 2024/01/19 03:27:22 王凯 wrote: > >> > 在使用flink cdc进行数据同步时,添加--scan.newly-added-table.enabled=true > >> > 参数,当从savepoint重启时,新添加的表的数据不能同步 > >> > > >> > > >> > 王凯 > >> > 2813732...@qq.com > >> > > >> > > >> > > >> > >
Re:RE: RE: flink cdc动态加表不生效
想知道oracle cdc connector不支持动态加表的原因是什么?可否自己扩展实现呢? 在 2024-01-19 11:53:49,"Jiabao Sun" 写道: >Hi, > >Oracle CDC connector[1] 目前是不支持动态加表的。 > >Best, >Jiabao > >[1] >https://ververica.github.io/flink-cdc-connectors/release-2.4/content/connectors/oracle-cdc.html > > >On 2024/01/19 03:37:41 Jiabao Sun wrote: >> Hi, >> >> 请提供一下 flink cdc 的版本,使用的什么连接器。 >> 如果方便的话,也请提供一下日志。 >> 另外,table 的正则表达式可以匹配到新增的表吗? >> >> Best, >> Jiabao >> >> [1] >> https://ververica.github.io/flink-cdc-connectors/release-3.0/content/connectors/mysql-cdc%28ZH%29.html#id15 >> >> On 2024/01/19 03:27:22 王凯 wrote: >> > 在使用flink cdc进行数据同步时,添加--scan.newly-added-table.enabled=true >> > 参数,当从savepoint重启时,新添加的表的数据不能同步 >> > >> > >> > 王凯 >> > 2813732...@qq.com >> > >> > >> > >> >