问答 2023-07-26 来自:开发者社区

flink cdc source mysql sink kafka 报包冲突 如何解决?

问题1:flink cdc source mysql sink kafka 报包冲突 如何解决?问题2:这个也看不出问题。我cdc 2.4 flink 1.13.6

问答 2023-07-26 来自:开发者社区

Flink CDC中mysql cdc 零点刚过时,大量同步数据,出现部分更新数据丢失的情况怎么办?

Flink CDC中mysql cdc 零点刚过时,大量同步数据,出现部分更新数据丢失的情况吗,具体现象就是30秒左右,同一个数据出现了2次以上的变更,但是下游只更新了一部分,或者干脆没更新。cdc 版本2.2.1,写到doris。变更的字段是非主键字段。

高性能

基于 Flink CDC 打造企业级实时数据同步方案

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2023-07-26 来自:开发者社区

Flink CDC中这种cdc全量采集的时候监控源表这个反压百分100,是因为我的MySQL太慢了?

Flink CDC中这种cdc全量采集的时候,监控源表这个反压百分100,是因为我的MySQL太慢了吗?

问答 2023-07-24 来自:开发者社区

Flink CDC中mysql不能设置水位线,那如何设置ttl?

Flink CDC中mysql不能设置水位线,那如何设置ttl?我是更具soure表进行操作的,但soure表会越来越大,同时还会对维表查找,维表也会越来越大。

问答 2023-07-24 来自:开发者社区

Flink CDC中这个报错如何解决?cdc2.4,flink1.6,mysql8

Flink CDC中这个报错如何解决,cdc2.4,flink1.6,mysql8;Flink SQL> select * from mysql_binlog;[ERROR] Could not execute SQL statement. Reason:java.lang.ClassCastException: cannot assign instance of com.ververica...

问答 2023-07-24 来自:开发者社区

Flink CDC中这个报错什么原因?flink cdc 2.3版本,mysql版本5.7.34

问题1:Flink CDC中Caused by: io.debezium.DebeziumException: Received DML 'update jobs set reserved_at = 1689564606, attempts = 1 where id = 43742' for processing, binlog probably contains events generate....

问答 2023-07-24 来自:开发者社区

Flink CDC中我本地测试mysql-cdc从指定时间戳启动,一直没有成功呢是什么原因?

Flink CDC中我本地测试mysql-cdc从指定时间戳启动,一直没有成功呢是什么原因?使用的是dataStream的方式,flink的版本:1.15.3,mysql的版本:8.0.18, connector的版本:flink-connector-mysql-cdc 2.4.0。测试代码:

问答 2023-07-24 来自:开发者社区

flink cdc中,我就是oracle单表到mysql单表,通过sql写的,这种怎么打散呢 ?

flink cdc中,我就是oracle单表到mysql单表,通过sql写的,这种怎么打散呢 ?sql怎么操作?insert into sink_tableselect ID,NAME,AGEfrom source_table;

问答 2023-07-19 来自:开发者社区

请问flink cdc中source Mysql 报这个错 什么原因?

请问flink cdc中source Mysql 报这个错 什么原因?

问答 2023-07-19 来自:开发者社区

请问flink cdc中独立项目集成flink jar 部署,多实例时,如何解决监听Mysql?

请问flink cdc中独立项目集成flink jar 部署,多实例时,如何解决监听Mysql 时,重复消费(每个实例都会监听到同一条数据的变化) 的问题?spring集成了,比如有一个集群 ,多个实例,监听同

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

产品推荐

实时计算 Flink

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

+关注