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

想问个事,Flink CDC中现在要实现mysql所有表同步到doris功能,但是mysql有20?

想问个事,Flink CDC中现在要实现mysql所有表同步到doris功能,但是mysql有20个实例,那么要如何配置才能实现所有表同步呢?

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

各位老师好 Flink CDC中 ck 的 MaterializeMySQL存储引擎从mysql ?

问题1:各位老师好 Flink CDC中 ck 的 MaterializeMySQL 存储引擎从mysql 伪同步过来整个库 可以创建表和 视图吗 第一次用 不太熟悉还望指教 ? 问题2:怎么创建 还望指点下 没事阻塞 我压测下

高性能

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

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

大佬们 flink cdc 读取MySQL数据写入Kafka,里面的金额字段,这个该如何解决?

问题1:大佬们 flink cdc 读取MySQL数据写入Kafka,里面的金额字段(MySQL decemial()类型)数据和MySQL的不一致,这个该如何解决? 我也纳闷怎么到了Kafka 就变成了字符串 问题2:utf8

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

大佬,问下Flink CDC中现在增量读取mysql数据,如果有新增的表想要全量读取,有哪几种方式?

问题1:大佬,问下Flink CDC中现在增量读取mysql数据,如果有新增的表想要全量读取,有哪几种方式呀 ? 问题2:这个参数需要改吗,我看官网没写这个参数,我现在是latest(): .startupOptions(StartupOptions.latest())

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

大佬们,flink cdc 2.2.1 读取mysql表,现在的读取方式是 latest(),如果?

大佬们,flink cdc 2.2.1 读取mysql表,现在的读取方式是 latest(),如果mysql新增了一张表,我想全量同步这张表。 把作业停掉,手动加上这张表,再读取之前的checkpoint位置,会全量同步新增的这张表吗? 我在本地测试了一下,之后的数据可以读取到,但是初始化部分的数据读取不到··

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

flink cdc消费到mysql表中0000-00-00 00:00:00时间值会出错吗?

flink cdc消费到mysql表中0000-00-00 00:00:00时间值会出错吗?

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

有人用Flink CDC同步mysql的information_schema的表吗? 这视图后面有实

有人用Flink CDC同步mysql的information_schema的表吗? 这视图后面有实体吗?

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

问个技术点,有大佬帮忙释疑下吗? flink cdc mysql source开了4个并发,特意指

问个技术点,有大佬帮忙释疑下吗? flink cdc mysql source开了4个并发,特意指定了一个servierId。他提示serverid范围必须大于等于source的并发度。但是快照阶段其实是读取全量表,这时候用不到从库吧。从库监听读取binlog时需要一个serverid就可以了,为什么需要多个呢?

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

各位大哥们,flink CDC读mysql,对于库里存在的无主键的表,有配置可以设置让他忽略这些表?

各位大哥们,flink CDC读mysql,对于库里存在的无主键的表,有配置可以设置让他忽略这些表,不报错不?

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

Flink CDC中千万数据的mysql 订单表和 10万数据的商品表 用 flinksql同步到?

问题1:Flink CDC中千万数据的mysql 订单表和 10万数据的商品表 用 flinksql同步到 一个大宽表的时候taskheap内存占用越来越多 同步到 几十万数据的时候内存就占满了。又遇到过的吗? 问题2: INSERT INTO p_enriched_order SELECT o.,p. FROM p_code_order AS o LEFT JOIN p_product AS ....

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

产品推荐

实时计算 Flink

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

+关注