AI 助理
备案控制台
开发者社区 大数据与机器学习 实时计算 Flink 正文

flink CDC2.3支持动态schema吗？

flink CDC2.3支持动态schema吗？

展开
收起
爱喝咖啡嘿 2022-12-09 16:42:42 276 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 清风拂袖

    是的，Flink CDC 2.3 支持动态 schema。

    动态 schema 是指表的 schema 可以随着时间的推移而发生变化，例如添加或删除字段。Flink CDC 2.3 通过以下方式支持动态 schema：

    基于时间戳的快照： Flink CDC 会定期为表创建快照，每个快照包含该时间点的完整表 schema。
    增量变更： 当表 schema 发生变化时，Flink CDC 会捕获增量变更，包括添加、删除或修改字段。

    2024-02-27 17:52:07
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版schema 实时计算 Flink版动态 实时计算 Flink版cdc2.3
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
实时计算Flink报错schema evolution table operations t...
74
0
0
Flink CDC里我cdc2.3升级3.0，flink最低版本要求是多少？
131
1
0
flink cdc用cdc-mysql 抽的数据有没有办法把dbz-json的schema去掉？
84
1
0
在Flink CDC中用3.1.1版本监听schema，出现中文乱码，这个有什么解决方案吗？
129
0
0
在Flink CDC中MySQL 整库同步 Kafka，不支持动态加表功能吗？
140
1
0
Flink CDC是不是sqlserver动态加表有bug还是有依赖没引入进来？
79
0
0
对于Flink CDC，schema中fields的name是指字段名字吗？
79
1
0
对于Flink CDC，动态表可以注册source吗？我理解动态表不是flink的吗？
76
0
0
对于Flink CDC，动态表source怎么add到env里输出给sink？
77
0
0
在Flink CDC中有版本支持oracle动态加表吗（一个任务同步多张表，可以动态添加订阅）？
156
1
0
大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问
收录在圈子:
阿里云实时计算Flink
199212
+ 订阅
实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

相关文章

  • 抖音基于 Flink 的 DataOps 能力实践
  • 零代码2小时搭建一套轻量级ERP系统
  • 规则引擎开发现在已经演化成算法引擎了
  • H5页面适配大屏和小屏的方案
  • 除了Foldables.js库，还有哪些库可以实现折叠屏适配？

    • 热门讨论

    热门文章

  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • flink的1cu是指1cpu还是1cpu+4g存储？
  • 请问如何用flink sql客户端用yarn application模式提交任务呢？
  • 请问下大家有没有遇到过这个错:Caused by: java.lang.ClassNotFoundE
  • Flink-CDC 文档网站地址是什么？
  • 在斗鱼，实时计算发展的历程如何？
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
  • 在Flink CDC中ogg可以做实时同步吗？
  • Flink获取消费kafka的时候始终获取不到topic列表是啥原因啊？
  • 求教一个问题：我使用flinkcdc采集Oracle 19C数据报错如下：用了什么解决方案？
    • 展开全部
  • 从 Storm 到 Flink，汽车之家基于 Flink 的实时 SQL 平台设计思路与实践
  • 阿里重磅开源全球首个批流一体机器学习平台Alink，Blink功能已全部贡献至Flink
  • Apache Flink 的迁移之路，2 年处理效果提升 5 倍
  • 【阿里内部应用】基于Blink构建搜索全链路debug系统快速定位搜索问题
  • 用Flink取代Spark Streaming！知乎实时数仓架构演进
  • 如何在 Apache Flink 1.10 中使用 Python UDF?
  • 58 集团大规模 Storm 任务平滑迁移至 Flink 的秘密
  • OPPO 实时数仓揭秘：从顶层设计实现离线与实时的平滑迁移
  • Netflix：如何打造开放协作的实时 ETL 平台？
  • 重磅！Apache Flink 1.11 功能前瞻抢先看！
    • 展开全部
    还有其他疑问?
    咨询AI助理