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

我用Flink CDC 去监控mysql 有三个字段是日期类型的 但是cdc读出来为什么是数据啊?

我用Flink CDC 去监控mysql 有三个字段是日期类型的 但是cdc读出来为什么是数据啊! 这是什么鬼

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

请问Flink CDC mysql2.4.0 的忽略无主键表 我看到这个参数··请问怎么设置?

问题1:请问Flink CDC mysql2.4.0 的忽略无主键表 我看到这个参数··请问怎么设置? scan.incremental.snapshot.chunk.key-column?我也刚刚看到代码部分了· /** * The chunk key of table snapshot, captured tables are split into multiple chunks by t.....

高性能

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

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

是不是有问题啊,我引入的Flink CDC同步mysql的jar?我想用最新版本的2.4.0

是不是有问题啊,我引入的Flink CDC同步mysql的jar? 我想用最新版本的2.4.0

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

Flink CDC 中mysql 的 time 对应 cdc 的 timestamp 类型吗?

Flink CDC 中mysql 的 time 对应 cdc 的 timestamp 类型吗?

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

大佬,请教下用Flink CDC读mysql这种报错要怎么解决?

问题1:大佬,请教下用Flink CDC读mysql这种报错要怎么解决? 问题2:发布的2.4.0版本MongoDBSource跟源码中的不一样,没有继承IncrementalSource

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

请问Flink CDC中有数据库方言转换方案推荐吗?客户现场存在异构数据源的同一系统,如mysql版

问题1:请问Flink CDC中有数据库方言转换方案推荐吗?客户现场存在异构数据源的同一系统,如mysql版本、达梦数据库版本,现在客户想实现两套系统进行数据实时同步功能。我的思路是,通过拦截SQL方式通过消息中间件(kafka、rabbitmq)发送给另外一个节点,节点收到数据后,进行一个SQL解析和转换,把源SQL转换为当前设备数据库SQL。我打算通过mybatis,把sql拦截下来,然后通....

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

Flink CDC中The MySQL server has a 兄弟们这个错误咋搞啊?

Flink CDC中The MySQL server has a timezone offset (0 seconds ahead of UTC) which does not match the configured timezone Asia/Shanghai 兄弟们这个错误咋搞啊?

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

Flink CDC中MySQL CDC 支持读取无主键表,这个是表不在合并了吗?

Flink CDC中MySQL CDC 支持读取无主键表,这个是表不在合并了吗?

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

有没有Flink CDC同步Rds Mysql的教程啊?Rds开启binlog跟Mysql有点不一样

有没有Flink CDC同步Rds Mysql的教程啊?Rds开启binlog跟Mysql有点不一样,binlog的配置

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

Flink CDC中·mysql监听整个库的时候,数据库里新增有一张表没有设置主键~会导致整个?

Flink CDC中·mysql监听整个库的时候,数据库里新增有一张表没有设置主键~会导致整个flink job挂掉··有什么办法可以忽略掉这个错误·让任务正常运行吗?监听整个数据库就是为了 动态监听新增的表~ 做排除的话等于要设定table list··就不符合原先的想法了,mysql不设置的情况下~会有一个隐藏主键~所以有一些开发会某些表不做设置

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

产品推荐

实时计算 Flink

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

+关注