问答 2023-12-11 来自:开发者社区

Flink CDC中postgrecdc2.4.1 从指定时间戳同步数据?

Flink CDC中postgrecdc2.4.1 从指定时间戳同步数据? properties.setProperty("startup.mode","timestamp"); properties.setProperty("startup.timestamp-millis","1626169100000L"); 这样配置没有生效,正确的要如何配置啊

问答 2023-12-10 来自:开发者社区

Flink CDC进行多表的数据 全量+增量 同步,报错日志如下?

Flink CDC进行多表的数据 全量+增量 同步,测试发现表数量为23个时还能正常运行(有部分任务失败会自动重启成功),在往上(比如24,25,26张表)就不能成功了(有部分任务失败且自动重启也不成功)。报错日志如下。我提交任务的运行语句如下.:./bin/flink run-application --target kubernetes-application -Dkubernetes.cl....

高性能

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

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

Flink CDC测试使用initial模式,使用savepoint停掉,不会做全量同步?

Flink CDC测试使用initial模式,使用savepoint停掉,删除一个表后,再使用savepoint启动,然后再使用savepoint停掉,加上表,再使用savepoint启动,最终加进去的这个表只会做增量同步,不会做全量同步?

问答 2023-12-10 来自:开发者社区

使用Flink CDC同步获取oracle11g的数据,初始化的时候有将表数据获取到,这怎么排查?

使用Flink CDC同步获取oracle11g的数据,初始化的时候有将表数据获取到,但是后面表数据变化了cdc没有获取到变化的数据,也没有报错啥的,这怎么排查?

问答 2023-12-10 来自:开发者社区

Flink CDC这么多union。如果数据库删除数据,能正常把删除的同步过去吗?

Flink CDC这么多union。然后再和jdbc关联,如果数据库删除数据,能正常把删除的同步过去吗?

问答 2023-12-10 来自:开发者社区

flink cdc能一次性同步sqlserver某个库下几百张表么?

flink cdc能一次性同步sqlserver某个库下几百张表么?

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

Flink CDC这个CDAS 在阿里云上可以实现, 开源的flink 支持CDAS 整库同步吗?

Flink CDC这个CDAS 在阿里云上可以实现, 开源的flink 支持CDAS 整库同步吗?

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

Flink CDC中oracle同步到tidb需要依赖哪些包哇?

Flink CDC中oracle同步到tidb需要依赖哪些包哇?

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

Flink CDC同步MySQL到ES时候,源表新增字段,大家怎么把这个改变同步到es 的?

Flink CDC同步MySQL到ES时候,源表新增字段,大家怎么把这个改变同步到es 的?

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

Flink CDC 无法从检查点处恢复pg同步任务,而是从头对pg数据库又消费了一遍?

Flink CDC 1.13.2、flinkcdc 2.2.1、postgresql 13.82.问题:使用cdc对pg做数据同步时checkpoint可以正常触发保存到hdfs,当任务取消后再从checkpoint进行任务恢复时,无法从检查点处恢复pg同步任务,而是从头对pg数据库又消费了一遍?

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

产品推荐

阿里云实时计算Flink

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

+关注