AI 助理
备案控制台
开发者社区 问答 正文

各位大佬，flink cdc2.3.0怎么实时同步ddl到iceberg？有样例吗？

各位大佬，flink cdc2.3.0怎么实时同步ddl到iceberg？有样例吗？

展开
收起
真的很搞笑 2023-04-19 13:02:56 334 分享 版权
来自： 阿里云实时计算Flink

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

1 条回答
写回答
取消 提交回答
  • TiAmoZhang
    CSDN全栈领域优质创作者，万粉博主；InfoQ签约博主；华为云享专家；华为Iot专家；亚马逊人工智能自动驾驶（大众组）吉尼斯世界纪录获得者

    Flink CDC 2.3.0可以通过以下步骤实时同步DDL到Iceberg:

    1. 安装Iceberg和Flink CDC插件。

    2. 在Flink项目中添加Iceberg元数据存储。

    3. 在Flink程序中启用CDC插件，并配置连接到Iceberg元数据存储的参数。

    4. 在Flink程序中添加DDL语句，以便在CDC过程中创建或更新表结构。

    5. 运行Flink程序以将DDL同步到Iceberg元数据存储中。

    6. 如果需要，可以使用Flink SQL查询工具来检查同步状态和表结构。

    需要注意的是，CDC插件只能同步DDL语句到Iceberg元数据存储中，而不能直接同步数据。如果需要实时同步数据，请考虑使用其他数据同步技术，如Kafka、Flume等。

    2023-05-12 17:01:13
    赞同 展开评论
问答分类：
SQL 流计算 实时计算 Flink版
问答标签：
实时计算 Flink版Iceberg 实时计算 Flink版ddl iceberg 实时计算 Flink版DDL 实时计算 Flink版实时同步 实时计算 Flink版cdc2.3.0
问答地址：
开发者社区 > 阿里云实时计算Flink > 问答
相关问答
Flink + Iceberg数据湖解决方案在小米的未来规划是什么？
111
1
0
使用flink-cdc-3.2.1实时同步sqlserver2019数据库名称有特殊字符问题
118
0
0
flink cdc实时同步oracle数据库到kafka报错
225
2
0
Flink CDC 实时同步 Doris 遇到下面的问题 怎么解决？
206
1
0
dataworks数据集成的‘实时同步’功能是通过flink cdc实现的吗，有没有介绍文档？
132
1
0
flink实时同步这边对源库和目标的版本要求是啥？
48
1
0
Flink mysql的5.6版本的备库不支持做增量的实时同步么？
55
0
0
Flink在写入Iceberg表时，如何确保主键相同的数据写入到同一个bucket？
161
1
0
为什么选择Flink和Iceberg来构建实时湖仓一体的架构？
108
1
0
flink cdc 遇到不能处理的ddl怎么办 可以提前在flinksql中过滤掉么？
85
1
0