问答 2023-08-22 来自:开发者社区

大哥们,怎么用flink cdc实现MySQL到MySQL整库的同步?

大哥们,怎么用flink cdc实现MySQL到MySQL整库的同步?

问答 2023-08-22 来自:开发者社区

各位大佬好,我想咨询下,使用Flink CDC链接mysql,我想要在其中某个字段在修改的时候,?

各位大佬好,我想咨询下,使用Flink CDC链接mysql,我想要在其中某个字段在修改的时候,触发某些操作,应该怎么处理?就是想要获取其中一条数据更新之前和之后的值。

高性能

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

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

Flink CDC用本地 flink(源码启动)调用线上mysql, 可以 用线上flink?

Flink CDC用本地 flink(源码启动)调用线上mysql, 可以用线上flink(docker启动)调用线上mysql, 第一次报错 db.table 找不到, 第二次报错java.lang.ClassNotFoundException: com.fasterxml.jackson.databind.ObjectMapper,docker 的 是需要进行什么特殊配置吗? parent.....

问答 2023-08-22 来自:开发者社区

Flink CDC增量监听Mysql的数据,如何停机更新的话,那这停机更新这部分新增的数据要怎么?

Flink CDC增量监听Mysql的数据,如何停机更新的话,那这停机更新这部分新增的数据要怎么处理?

问答 2023-08-22 来自:开发者社区

hey 哪位专家帮忙解答下,Flink CDC mysql cdc 如何关闭incrementa?

hey 哪位专家帮忙解答下,Flink CDC mysql cdc 如何关闭incremental snapshot呢?使用方式是datastream api。

问答 2023-08-20 来自:开发者社区

Flink CDC有大佬了解这个报错吗?监听mysql出现死锁问题!

Flink CDC有大佬了解这个报错吗?监听mysql出现死锁问题

问答 2023-08-20 来自:开发者社区

Flink CDC我把原表加个主键能够print出来了, 不知道原因在哪。默认是mysql表要有主?

Flink CDC我把原表加个主键能够print出来了, 不知道原因在哪。默认是mysql表要有主键吗?无主键在chunks的时候就无法进行了?

问答 2023-08-20 来自:开发者社区

我想问下Flink CDC, 读取mysql print不出来,但是原表里面是由数据的 ,这种是什?

我想问下Flink CDC, 读取mysql print不出来,但是原表里面是由数据的 ,这种是什么情况?

问答 2023-08-16 来自:开发者社区

flink cdc使用连接的mysql账号一定需要锁表权限吗?

flink cdc使用连接的mysql账号一定需要锁表权限吗,只有读取权限的账号有什么方式可以连接启动吗?

问答 2023-08-16 来自:开发者社区

Flink CDC获取到 MySQL 修改值后要执行一条 100 多行sql如何实现?

Flink CDC获取到 MySQL 修改值后要执行一条 100 多行的sql 去 MySQL 重新捞取数据插入到 es 中,该如何实现?这条 sql 涉及到 5 张表,用 flinksql 每张表都要映射吗?有没有简单的方法,直接执行 sql 。

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

产品推荐

实时计算 Flink

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

+关注