You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2022/09/26 15:27:05 UTC
flink cdc能否同步DDL语句?
flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate table等
Re: Re: flink cdc能否同步DDL语句?
Posted by Shengkai Fang <fs...@gmail.com>.
Hi.
可以从这个地方入手看看
https://github.com/ververica/flink-cdc-connectors/blob/master/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/reader/MySqlRecordEmitter.java#L95
Best,
Shengkai
casel.chen <ca...@126.com> 于2022年10月11日周二 10:58写道：
> 可以给一些hints吗？看哪些类?
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2022-10-11 10:22:07，"yuxia" <lu...@alumni.sjtu.edu.cn> 写道：
> >用 datastream api，自己解析一下 DDL。
> >
> >Best regards,
> >Yuxia
> >
> >----- 原始邮件 -----
> >发件人: "yh z" <zh...@gmail.com>
> >收件人: "user-zh" <us...@flink.apache.org>
> >发送时间: 星期二, 2022年 10 月 11日 上午 10:23:43
> >主题: Re: flink cdc能否同步DDL语句?
> >
> >目前，社区的 Flink CDC，是可以读取到 binlog 中的 DDL 语句的，但是不会传递给下游，即下游无法感知 schema 的变化。
> >
> >Xuyang <xy...@163.com> 于2022年10月10日周一 16:46写道：
> >
> >> Hi， 目前应该是不行的
> >> 在 2022-09-26 23:27:05，"casel.chen" <ca...@126.com> 写道：
> >> >flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate
> >> table等
> >>
>
Re:Re: flink cdc能否同步DDL语句?
Posted by "casel.chen" <ca...@126.com>.
可以给一些hints吗？看哪些类?
在 2022-10-11 10:22:07，"yuxia" <lu...@alumni.sjtu.edu.cn> 写道：
>用 datastream api，自己解析一下 DDL。
>
>Best regards,
>Yuxia
>
>----- 原始邮件 -----
>发件人: "yh z" <zh...@gmail.com>
>收件人: "user-zh" <us...@flink.apache.org>
>发送时间: 星期二, 2022年 10 月 11日 上午 10:23:43
>主题: Re: flink cdc能否同步DDL语句?
>
>目前，社区的 Flink CDC，是可以读取到 binlog 中的 DDL 语句的，但是不会传递给下游，即下游无法感知 schema 的变化。
>
>Xuyang <xy...@163.com> 于2022年10月10日周一 16:46写道：
>
>> Hi， 目前应该是不行的
>> 在 2022-09-26 23:27:05，"casel.chen" <ca...@126.com> 写道：
>> >flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate
>> table等
>>
Re: flink cdc能否同步DDL语句?
Posted by yuxia <lu...@alumni.sjtu.edu.cn>.
用 datastream api，自己解析一下 DDL。
Best regards,
Yuxia
----- 原始邮件 -----
发件人: "yh z" <zh...@gmail.com>
收件人: "user-zh" <us...@flink.apache.org>
发送时间: 星期二, 2022年 10 月 11日 上午 10:23:43
主题: Re: flink cdc能否同步DDL语句?
目前，社区的 Flink CDC，是可以读取到 binlog 中的 DDL 语句的，但是不会传递给下游，即下游无法感知 schema 的变化。
Xuyang <xy...@163.com> 于2022年10月10日周一 16:46写道：
> Hi， 目前应该是不行的
> 在 2022-09-26 23:27:05，"casel.chen" <ca...@126.com> 写道：
> >flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate
> table等
>
Re: flink cdc能否同步DDL语句?
Posted by yh z <zh...@gmail.com>.
目前，社区的 Flink CDC，是可以读取到 binlog 中的 DDL 语句的，但是不会传递给下游，即下游无法感知 schema 的变化。
Xuyang <xy...@163.com> 于2022年10月10日周一 16:46写道：
> Hi， 目前应该是不行的
> 在 2022-09-26 23:27:05，"casel.chen" <ca...@126.com> 写道：
> >flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate
> table等
>
Re:flink cdc能否同步DDL语句?
Posted by Xuyang <xy...@163.com>.
Hi， 目前应该是不行的
在 2022-09-26 23:27:05，"casel.chen" <ca...@126.com> 写道：
>flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate table等