flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

ddl support

Open sunfu103 opened this issue 3 years ago • 7 comments

什么时候支持ddl? 上游数据源schema修改 flink-cdc可以自动修复下游动态表schema

sunfu103 avatar Jan 13 '22 03:01 sunfu103

这个如果使用 Stream API 的话是已经支持了的,includeSchemaChanges 置为 true 可以保证数据流中包含 DDL,可以在 stream job 中进行相应处理。

zhjwpku avatar Jan 20 '22 07:01 zhjwpku

SQL 方式自动同步 schema 由云邪老师带领的团队开发过了,但尚未开源,目前只能自己通过Stream API 来解决。

gtk96 avatar Jan 21 '22 12:01 gtk96

SQL 方式自动同步 schema 由云邪老师带领的团队开发过了,但尚未开源,目前只能自己通过Stream API 来解决。

是指阿里云Flink的CDAS和CTAS吗?可以支持gh-ost相关DDL,以及下游为MySQL / TiDB么?

teckick avatar Feb 10 '22 06:02 teckick

这个功能很重要,现在主流的数据湖工具都已经支持了,希望可以开源,尽快加入。

jinghewang avatar Feb 10 '22 09:02 jinghewang

+1

zfanswer avatar Apr 01 '22 10:04 zfanswer

+1

caijiljh avatar Apr 12 '22 02:04 caijiljh

+1

yuandajn578 avatar Sep 19 '22 07:09 yuandajn578

+1

tianhao960 avatar Oct 18 '22 10:10 tianhao960

+1

JageChen avatar Nov 11 '22 10:11 JageChen

+1

giangnth avatar Dec 21 '22 04:12 giangnth

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!

PatrickRen avatar Feb 28 '24 15:02 PatrickRen