文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之哪个版本可以做增量快照算法

问题一:现在flink cdc 接入mysql 表时 表新增字段 还会导致同步任务重新初始化吗 ? 现在flink cdc 接入mysql 表时 表新增字段 还会导致同步任务重新初始化吗 ? 参考回答: 不会 关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567402 ...

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之是否支持对每个表的增量快照键列进行单独配置

问题一:Flink CDC没有按照主键的所有列而是只按照主键的第1个列split chunk的原因是啥呢? Flink CDC没有按照主键的所有列而是只按照主键的第1个列split chunk的原因是啥呢? 参考回答: Flink CDC的split chunk操作是根据主键进行的,而不是根据所有列。这是因为主键是用来唯一标识一行数据的字段,因此使用主...

实时计算 Flink版产品使用合集之是否支持对每个表的增量快照键列进行单独配置
问答 2024-05-07 来自:开发者社区

Flink CDC里这个必须使用没有增量快照的模式进行同步吗?

Flink1.15、Oracle19c、FlinkCDC2.4.2,CDB+PDB模式,数据无法同步,指定了PDB和CDB,看情况似乎是cdc在CDB里找要同步的表,但是需要同步的表在PDB里,有什么办法解决吗?

问答 2024-02-06 来自:开发者社区

Flink CDC里使用增量快照,怎么读取最近一次的checkpoint?

Flink CDC里使用增量快照'scan.incremental.snapshot.enabled'='true,启动模式'scan.startup.mode'='initial',checkpoint已经写S3假设jobmanager崩溃重启,如何读取最近一次的checkpoint?现在是出现sink重复数据的问题呢?

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

flink cdc intial 模式下先读全量再读增量,如果快照读取是否会导致数据重复消费?

flink cdc intial 模式下,先读全量再读增量,拿mysql cdc 举例,如果快照读取完毕,如下图,还会backfill在读期间新增的binlog 数据。那如果在快照读取节点是并发读取,是否会导致binlog数据重复消费?

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

Flink CDC里增量快照是单个作业内多并行度,但是多个作业、每个作业同步的不同库可以同时运行吗?

Flink CDC里增量快照是单个作业内多并行度,但是多个作业、每个作业同步的不同库,但不同库在一个实例下,这时能多个库的作业同时运行吗?怎么控制数据库中创建复制槽不阻塞呢?

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

Flink CDC 的增量快照读取机制进行了调研,这样的情况是否可能导致数据丢失问题?

Flink CDC 的增量快照读取机制进行了调研,并有一个问题想请教,如上图:当前表中共有9条数据,我设定了 chunk 切分粒度为scan.incremental.snapshot.chunk.size=5,并且作业并发为2。我的疑惑在于一个 binlog 记录,即 insert#10,假设它只被 chunk01 读取,但却不符合 chunk01 的分片范围,因此被丢弃。在后续的 MySqlS....

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

Flink CDC用rockdb增量快照 随着作业的运行 这个有什么解决办法吗 ?

Flink CDC用rockdb增量快照 随着作业的运行 MANIFEST 越来越大 导致 Checkpointed Data Size 更大,Checkpointe 用时更长了 这个有什么解决办法吗 ?420m了source 是mysqlconnector 连的mysql 和 doris ,sink 是doris

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

Flink CDC中oceanbase什么时候能支持增量快照呢?

Flink CDC中oceanbase什么时候能支持增量快照呢?

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

Flink的vvr6.0.8配合开源2.4.2版本,增量快照采集不到数据,这个需要提工单吗?

Flink的vvr 6.0.8 配合开源mongo-cdc 2.4.2版本,增量快照采集不到数据,这个需要提工单吗?vvr 8.0.1 使用你们公测的mongo-cdc 进行sql方式增量快照提取,是可以提取出来的

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

产品推荐

阿里云实时计算Flink

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

+关注