问答 2023-06-11 来自:开发者社区

大佬们,Flink cdc mysql同步报错:这个问题怎么解决呢?但是这个库的表实际上不是我要同步

大佬们,Flink cdc mysql同步报错:Incremental snapshot for tables requires primary key,这个问题怎么解决呢?但是这个库的表实际上不是我要同步的库,是扫描到这个实例下面其它库的表

问答 2023-06-11 来自:开发者社区

Flink CDC读取mysql到kafka,更新的话op不应该是u吗,出来是d和c?

Flink CDC读取mysql到kafka,更新的话op不应该是u吗,出来是d和c?

高性能

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

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

Flink CDC中mysql cdc只支持init 和latest两种模式吗?我看源码里就这两种,

Flink CDC中mysql cdc只支持init 和latest两种模式吗?我看源码里就这两种,其余的抛异常

问答 2023-06-11 来自:开发者社区

Flink CDC中本地写了个mysql 的demo,项目启动的时候数据计算了一遍,后面?

Flink CDC中本地写了个mysql 的demo,项目启动的时候数据计算了一遍,后面source数据发生变化,目标表数据没有更新,这个是什么原因,哪位大佬知道吗?

问答 2023-06-11 来自:开发者社区

请教一下各位大佬,flink cdc实时采集mysql的时候。业务高峰时段延迟将近10分钟,请问可?

请教一下各位大佬,flink cdc实时采集mysql的时候。业务高峰时段延迟将近10分钟,请问可以做哪方面的优化呀?

问答 2023-06-11 来自:开发者社区

你好,各位大佬们,我有个Flink CDC问题,我使用flink-mysql-cdc的在一个job?

你好,各位大佬们,我有个Flink CDC问题,我使用flink-mysql-cdc的MySQLSource在一个job同步了多张表,比如a,b和c,但是现在c需要进行整表重新同步,表a和表b继续进行原来的同步任务,这种有没有比较简单的方法实现,目前的方式是新开一个job单独同步表c,然后表c同步差不多了,再添加到原job,并且使用timestamp模式作为startupMode调整时间戳后重启....

问答 2023-06-11 来自:开发者社区

大佬们是如何处理需要Flink CDC 的数据库不可用的情况的,比如mysql崩了这种?

大佬们是如何处理需要Flink CDC 的数据库不可用的情况的,比如mysql崩了这种?

问答 2023-06-11 来自:开发者社区

Flink CDC中mysql cdc 报这个错 是啥原因导致的啊?

Flink CDC中mysql cdc 报这个错 是啥原因导致的啊?

问答 2023-06-11 来自:开发者社区

flink cdc在收到mysql binlog event时,是会等待其对应的被提交才下发这条?

flink cdc在收到mysql binlog event时,是会等待其对应的transaction被提交才下发这条binlog,还是会立即下发呢?

问答 2023-06-11 来自:开发者社区

请教一下大佬们,FLInk CDC 可以监听MySQL 表指定列的变更才进行sink吗?还是说需要自

请教一下大佬们,FLInk CDC 可以监听MySQL 表指定列的变更才进行sink吗?还是说需要自己实现?

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

产品推荐

实时计算 Flink

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

+关注