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

Flink CDC中sqlserver同步过程中,先全量然后增量,会出现直接暂停的现象,什么原因?

"Flink CDC中sqlserver同步过程中,先全量然后增量,会出现直接暂停的现象,我看代码似乎是触发了增量同步,然而实际上表并没有任何数据改动,如果数据库其他cdc表没有变动不会出现这个问题,实际上全量没有完全,在方法里面出不来了,什么原因?版本2.4.1。"

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

Flink CDC中oracle 2.4.1 没法没法同步数据是什么原因呢?

"Flink CDC中oracle 2.4.1 没法没法同步数据是什么原因呢?"

高性能

Flink CDC 实现企业级实时数据同步

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

Flink CDC中这个如何解决?cdc同步到hudi再同步到hive查询时间戳类型字段报错。

"Flink CDC中这个如何解决?cdc 同步到hudi再同步到hive,hive查询时间戳类型字段报错java.lang.IllegalArgumentException: Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff] at java.sql.Timestamp.valueOf(Timestamp.java:237) at ....

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

Flink CDC中同样的代码在cdc 2.4 打印这些日志,无法同步数据什么原因?

Flink CDC中同样的代码在cdc 2.4 打印这些日志,无法同步数据在cdc 2.3 能打印全量数据 不嫩怪打印增量,开了checkpointOracle版本是11.2.0.1Flink版本是1.14.6CDC 2.4 版本Oracle 这是啥问题啊?

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

Flink CDC中同一个sql同步到mysql少数据,同步到 es 没有问题,什么原因?

"Flink CDC中 同一个sql 同步到mysql 少数据,同步到 es 没有问题,是不是同步到mysql的时候需要做什么特殊处理,同步的sql :SET 'pipeline.name' = 'batch_order_statistics_job';SET 'table.exec.resource.default-parallelism'= '2';SET 'sql-client.execu....

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

flink cdc 按照字段分区同步写入,为啥那么占用资源的?

flink cdc 按照字段分区同步写入,为啥那么占用资源的?

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

Flink CDC 2.4 flink 14.6Oracle 不能正常同步数据,怎么解决?

Flink CDC 2.4 flink 14.6Oracle 不能正常同步数据,怎么解决?

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

Flink CDC中2.4.1,同步全库,中途mysql里加了表,cdc没有捕获到,什么原因?

Flink CDC中2.4.1,同步全库,中途mysql里加了表,cdc没有捕获到,什么原因?加了数据没动静。

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

Flink CDC中cdc 2.4 flink 14.6同步Oracle的时候这是咋回事?

"Flink CDC中cdc 2.4 flink 14.6同步Oracle的时候这是咋回事?file:///C:/Users/Administrator/AppData/Roaming/DingTalk/227792554_v2/resource_cache/6f/6fd934f8d0b4fc0cd0cb3c082392ef48.png不能正常跑,跑一会儿就异常了。"

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

Flink CDC中dinky 整库同步pg到hudi,知道这是什么原因?

问题1:Flink CDC中dinky 整库同步pg到hudi,知道这是什么原因?Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.apache.hudi.configuration.FlinkOptions问题2:pg整库同步到hudi并同步到hive网上下载的包hudi-flink1.13-bu....

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注