问答 2022-08-12 来自:开发者社区

大家有没有出现过 FLINK MySQL cdc 数据量太大时 无法接收到MySQL binlog情

大家有没有出现过 FLINK MySQL cdc 数据量太大时 无法接收到MySQL binlog情况,数据量少的时候没有问题,怎么解决的?

问答 2022-08-04 来自:开发者社区

mysql cdc 为什么需要RELOAD 这个权限?这个权限在采集数据的过程中的作用是什么?有哪

mysql cdc 为什么需要RELOAD 这个权限?这个权限在采集数据的过程中的作用是什么?有哪位大佬知道吗 ?

问答 2022-07-28 来自:开发者社区

mysql cdc 如果binlog日志文件不全,全量阶段能读到所有数据吗

mysql cdc 如果binlog日志文件不全,全量阶段能读到所有数据吗

问答 2022-06-30 来自:开发者社区

MySQL cdc jobmanager 中存了哪些比较耗内存的数据呢?

如题

问答 2022-06-23 来自:开发者社区

各位大佬,第一次使用flink mysql cdc, 现在程序启动 没报错 新增数据没有打印出来

请问可能的原因会是什么

文章 2022-06-13 来自:开发者社区

Flink Mysql CDC结合Doris flink connector实现数据实时入库

Flink Mysql CDC结合Doris flink connector实现数据实时入库Apache doris通过扩展支持通过 Flink 读写 doris 数仓中的数据表,目前 doris 支持 Flink 1.11.x ,1.12.x,1.13.x,Scala版本:2.12.x目前Flink doris connector目前控制入库通过两个参数:sink.batch.size :每多....

Flink Mysql CDC结合Doris flink connector实现数据实时入库
文章 2022-06-13 来自:开发者社区

Flink Mysql CDC结合Doris flink connector实现数据实时入库

Apache Doris 代码仓库地址:apache/incubator-doris 欢迎大家关注加星Apache doris通过扩展支持通过 Flink 读写 doris 数仓中的数据表,目前 doris 支持 Flink 1.11.x ,1.12.x,1.13.x,Scala版本:2.12.x目前Flink doris connector目前控制入库通过两个参数:sink.batch.siz....

问答 2022-02-15 来自:开发者社区

flink1.11 mysql cdc checkpoint 失败后程序自动恢复,同步数据出现重复

sourcr:mysql-cdc sink:elasticsearch 问题描述: 从mysql中同步表数据至elasticsearch后,进行新增再删除的某条数据出现问题,导致sink失败(没加primary key)。checkpoint失败,程序自动恢复重启后,checkpoint 成功,但是elasticsearch 中的数据是mysql 表中的两倍,出现重复同步情况。 程序的自动恢复.....

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