问答 2024-05-01 来自:开发者社区

Flink CDC里又遇到表全量同步后,不会继续增量同步。大佬们 有没有排查问题的思路呀?

Flink CDC里创建savepoint后,新加user_review_record表,然后从savepoint启动,启后全量同步完,就不继续增量了,怎么处理?

问答 2024-05-01 来自:开发者社区

Flink CDC做数据同步的时候 pg的bit(1) 怎么同步到pg另一个表的bit(1) 里去?

Flink CDC里做数据同步的时候 pg的bit(1) 怎么同步到pg另一个表的bit(1) 里面去 ?

高性能

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

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

flink cdc 配置了 MySQL同步到Doris, 这个是有啥参数配置吗?

flink cdc 配置了 MySQL同步到Doris, source配置了 tables: test..* ,MySQL有新增表的话但是Doris里面没有创建,重启CDC任务就可以?这个是有啥参数配置吗?

问答 2024-04-26 来自:开发者社区

Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,什么时候开始增量?

Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,如果十几个小时才能初始化完成,无锁算法开始增量的时候是从十几个小时前的binlog位点增量还是从当前时间位点增量?(如果是从十几个小时前的binlog位点衔接增量,如果binlog已经归档了,就会报错文件找不到)

问答 2024-04-26 来自:开发者社区

Flink CDC里oracle无主键的表支持同步吗?是2.4的版本么?

Flink CDC里oracle无主键的表支持同步吗?怎么实现?

问答 2024-04-23 来自:开发者社区

Flink CDC里我完全参考官方文档启动一个mysql到starrocks的同步怎么做啊?

Flink CDC里task manager的日志里没有新表的名字,感觉CDC检查不到新创建的表?tables:app_db..*这样配置新创建的表可以同步过去吗?

问答 2024-04-22 来自:开发者社区

Flink CDC里假如源库删除了某行数据,那么在CDC同步后会删除目标库中对应的数据吗?

Flink CDC里假如源库删除了某行数据,那么在CDC同步后会删除目标库中对应的数据吗?有没有办法在目标库中增加逻辑删除字段?

问答 2024-04-22 来自:开发者社区

Flink CDC里Oracle不支持大对象同步吗?

debezium作者说升级debezium版本可修复该问题,cdc社区啥时候考虑修复该问题呢?

问答 2024-04-22 来自:开发者社区

Flink CDC里昨天晚上同步的,这咋回事?

Flink CDC里昨天晚上同步的,早上发现目标库(doris)相对于源库(mysql)2.8亿条数据少了几千条,但flink-cdc任务没报错,于是重启了任务,才发现重头开始了。会是什么异常呀?

问答 2024-04-22 来自:开发者社区

Flink CDC里有没有大佬试过cdc3.0.0到doris管道模式全库同步啊?

Flink CDC里有没有大佬试过cdc3.0.0到doris管道模式全库同步。我这边按照git配置后,启用同步脚本报错org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type java.lang.St....

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

产品推荐

阿里云实时计算Flink

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

+关注