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 <casel_c...@126.com> 于2022年10月11日周二 10:58写道： > 可以给一些hints吗？看哪些类? > > > > > > > > > > > > > > > > > > 在 2022-10-11 10:22:07，"yuxia" <luoyu...@alumni.sjtu.edu.cn> 写道： > >用 datastream api，自己解析一下 DDL。 > > > >Best regards, > >Yuxia > > > >----- 原始邮件 ----- > >发件人: "yh z" <zhengyunhon...@gmail.com> > >收件人: "user-zh" <user-zh@flink.apache.org> > >发送时间: 星期二, 2022年 10 月 11日 上午 10:23:43 > >主题: Re: flink cdc能否同步DDL语句? > > > >目前，社区的 Flink CDC，是可以读取到 binlog 中的 DDL 语句的，但是不会传递给下游，即下游无法感知 schema 的变化。 > > > >Xuyang <xyzhong...@163.com> 于2022年10月10日周一 16:46写道： > > > >> Hi， 目前应该是不行的 > >> 在 2022-09-26 23:27:05，"casel.chen" <casel_c...@126.com> 写道： > >> >flink cdc能否同步DDL语句以实现schema同步? 例如create table , create index, truncate > >> table等 > >> >
