开发者社区> 问答> 正文

flink sql源表定义字段列表有问题怎么办?

采用flink sql定义源表时,哪些connector支持提供部分字段,哪些connector必须要提供全量字段呢? 这边常用的connector主要有kafka, jdbc, clickhouse和mysql-cdc。 cdc是不是必须要提供对应表的全量字段呢?如果上游mysql业务表新增了字段,flink sql作业会不会出错? kafka表定义是否支持部分字段?

展开
收起
EXCEED 2021-12-02 11:03:46 492 0
1 条回答
写回答
取消 提交回答
  • 不需要提供全部字段*来自志愿者整理的FLINK邮件归档

    2021-12-02 11:22:41
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载