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

Flink CDC中oracle到pg不是很常见吗?请教这各位,mysql的增量过程中,有没有遇到过

Flink CDC中oracle到pg不是很常见吗?请教这各位,mysql的增量过程中,有没有遇到过: no tablemapEventData has been found for table id…反序列化binlog日志过程中,说没有某个表的tablemapEvent,社区里有反馈这个问题:

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

我们通过Flink CDC时间戳偏移量读取mysql binlog,设置了checkpoint,一?

我们通过Flink CDC时间戳偏移量读取mysql binlog,设置了checkpoint,一个taskmanager挂掉,这个任务转移到另一个taskmanager上,报如下错误: Caused by: com.github.shyiko.mysql.binlog.network.ServerException: event read from binlog did not pass cr....

高性能

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

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

请问下,Flink CDC中MySQL同步es,es模型是嵌套的,大伙是怎么处理的?

请问下,Flink CDC中MySQL同步es,es模型是嵌套的,大伙是怎么处理的?

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

Flink CDC 中mysql cdc connector 初始化阶段,调用超时是什么原因?

Flink CDC 中mysql cdc connector 初始化阶段,调用com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils#listTables超时是什么原因?

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

请教下,我使用flink cdc -> flink jdbc在mysql之间同步某张表,发现使用表?

请教下,我使用flink cdc -> flink jdbc在mysql之间同步某张表,发现使用表主键作为PRIMARY KEY时才是UPSERT模式,使用唯一键时却是INSERT模式,这是正常的?

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

Flink CDC 中mysql timestamp全量读取的时间正常,增量阶段少8小时,有人遇到?

Flink CDC 中mysql timestamp全量读取的时间正常,增量阶段少8小时,有人遇到这情况?是要转,但是全量没少8小时

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

Flink CDC中mysql cdc2.3 维表join丢数据,大家有遇到过吗?也没错误日志,这种

Flink CDC中mysql cdc2.3 维表join丢数据,大家有遇到过吗?也没错误日志,这种情况怎么排查?偶尔丢一条,过几天又丢一条

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

Flink CDC中mysql cdc 2.3有参数设置全量阶段加where条件的么?dbz是有的,

Flink CDC中mysql cdc 2.3有参数设置全量阶段加where条件的么?dbz是有的,mysql的全量使用了无锁算法,还没看源码,不太清楚,这和重新同步全量一样了,我只是想从今天下午这时间点后的数据 ,而且都是通用代码

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

现在Flink CDC 并行度能不能设置成多个啊?这只是mysql服务端的配置吗,cdc有需要什么?

现在Flink CDC 并行度能不能设置成多个啊?这只是mysql服务端的配置吗,cdc有需要什么配置不?这种情况只能重跑了?生产用主库,同步数据不敢,持续连着同步的,有个问题,我有4个job连的同一个备库,就其中两个出现这个问题,另两个还正常跑着

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

Flink CDC 中sql server 不能像mysql那样指定 pos嘛?

Flink CDC 中sql server 不能像mysql那样指定 pos嘛?

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

产品推荐

实时计算 Flink

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

+关注