问答 2025-03-21 来自:开发者社区

flink1.19和hive3.1.3,cdc从mysql同步数据到hive,插入时报错?

使用的是flink sql处理流程是从mysql进kafka之后,通过kafka插入hive,在插入数据时会报错,选了upsert-kafka,sql没有更新或者删除操作 Flink SQL> [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.TableException: Table si...

阿里云文档 2025-02-08

MySQL连接器最佳实践

本文为您介绍MySQL连接器在常见使用场景下的最佳实践。

阿里云文档 2025-02-06

Flink订阅AnalyticDB for MySQL Binlog

实时计算 Flink 版通过订阅云原生数据仓库 AnalyticDB MySQL 版,可以实时捕获和处理数据库变更数据,实现高效的数据同步和流式计算。本文为您介绍如何使用Flink订阅AnalyticDB for MySQL Binlog。

阿里云文档 2024-10-08

MySQL连接器本地调试

本文为您介绍如何在本地IDEA调试和运行MySQL DataStream作业。

问答 2024-08-07 来自:开发者社区

flink mysql cdc2.4.2 运行几小时侯 就不同步数据了?

flink mysql cdc2.4.2 doris connector 1.6.1。遇到问题整库同步使用doris官方提供的命令形式 latest模式,开始运行没问题,运行几小时侯 就不同步数据了?

问答 2024-07-17 来自:开发者社区

Flink的mysql同步kafka 目前只能是kafka存储所有数据的么?

Flink的mysql同步kafka 目前只能是kafka存储所有数据的么?mysql -> flink cdc -> kafka -> flink -> sr 这个样子的

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之在从MySQL同步数据到Doris时,delete语句无法同步,是什么原因

问题一:Flink CDC里我是想自动做断点续传,比如我某个任务的容器crash了,我需要重启任务怎么办? Flink CDC里我是想自动做断点续传,比如我某个任务的容器crash了,我需要重启任务,这个时候没法预知去手动savepoint,该如何处理呢? 参考答案: 如果是mysql的话最好是 自己指定下 最新的 log bin.文件的位置,让从指定...

实时计算 Flink版产品使用问题之在从MySQL同步数据到Doris时,delete语句无法同步,是什么原因
问答 2024-07-12 来自:开发者社区

Flink MySQL cdc 同步时状态存储的是全表的数据吗?

是否会在增量阶段释放内存

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像