问答 2023-05-09 来自:开发者社区

大佬们,Flink CDC 中谁有mysql动态获取表结构变更的示例呀,

大佬们,Flink CDC 中谁有mysql动态获取表结构变更的示例呀,我加上includeSchemaChanges(true)不起作用,是不是还需要其他的配置?我flink-cdc的版本是2.2.1

问答 2023-05-09 来自:开发者社区

请问 flink cdc 的mysql连接器有没有监控输入了多少数据,速度是多少的接口

请问 flink cdc 的mysql连接器有没有监控输入了多少数据,速度是多少的接口

高性能

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

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

大佬们有遇到过 flink cdc mysql 一直报

大佬们有遇到过 flink cdc mysql 一直报 Trying to restore lost connection to

问答 2023-05-01 来自:开发者社区

Flink CDC中mysql cdc 可以获取 数据插入的时间吗?

Flink CDC中mysql cdc 可以获取 数据插入的时间吗?

问答 2023-05-01 来自:开发者社区

Flink CDC 中mysql主从同步可以从零开始吗,比如主库800g,单独的,现在搞个从库新的,

Flink CDC 中mysql主从同步可以从零开始吗,比如主库800g,单独的,现在搞个从库新的,可以全量同步过来吗

问答 2023-05-01 来自:开发者社区

flink cdc 报了这个错误,是哪里配置的不对吗?Caused by: com.mysql.cj

flink cdc 报了这个错误,是哪里配置的不对吗?Caused by: com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Lock wait timeout exceeded; try restarting transaction 我上面发的错误,看着显示锁表的错误呀,是哪里配置的不对吗?谁知道。flink cd.....

问答 2023-05-01 来自:开发者社区

Flink CDC中你那个时区问题怎么解决的呀,我这边mysql中 timestamp 类型的数据,

Flink CDC中你那个时区问题怎么解决的呀,我这边mysql中 timestamp 类型的数据,用mysql 客户端查询没有问题,但是用 cdc 导出来 就差8小时,怎么办?

问答 2023-05-01 来自:开发者社区

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时差多了八个小时,当时让我看MySQL的时区是Asia/Shanghai (CST,+0800)? 就是有个问题是,我这边有两个业务库,时区都是一样的,只有这个同步过来时区+8小时,另外的那个是正常的,这个是什么原因?我这样加 不对,正确的如何加呀?

问答 2023-05-01 来自:开发者社区

咨询下Flink CDC 中mysql binlog 太大导致oom的问题,几分钟更新了600w数据

咨询下Flink CDC 中mysql binlog 太大导致oom的问题,几分钟更新了600w数据,binlog能切分段过来吗?

问答 2023-05-01 来自:开发者社区

Flink CDC中为啥我的mysql cdc 设置并行度为2,全量扫描阶段特别慢呢,还不如一个任务

Flink CDC中为啥我的mysql cdc 设置并行度为2,全量扫描阶段特别慢呢,还不如一个任务,有时候直接卡主在某个点,有人知道吗 就是sink表的总数没达到期望的值,我把并行度设置为1,这个值为4万多,也符合预期,这个一直卡在28292了,好久了,我是本地,也没法用web ui看 按照网上的设置本地webui也不起作用,直接返回{"errors":["Not found."]}flink....

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

产品推荐

实时计算 Flink

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

+关注