问答 2025-01-10 来自:开发者社区

请问一下 Flink CDC 方式同步,目标数据量比源数据偏多问题

同步方式:PIPELINE source源:mysql sink源:starrocks 问题:初始化同步后,部分starrock表的数据比抽取的mysql源表还多 特点:mysql业务库使用了seata中间件做分布式事务,有物理删除行为

文章 2024-08-26 来自:开发者社区

联通实时计算平台问题之Flink状态后端数据量较大时,问题排查要如何进行

问题一:如何进行端到端的时延监控? 如何进行端到端的时延监控? 参考回答: 通过事件时间的打标(如进出Kafka时间),结合抽样方式计算算子的延迟,以及监控Kafka offset的积压断传来实现端到端时延监控。 关于本问题的更多回答可点击原文查看: https://developer.aliyun.com/ask/67081...

问答 2024-07-29 来自:开发者社区

Flink状态后端数据量较大时,如何进行问题排查?

Flink状态后端数据量较大时,如何进行问题排查?

问答 2024-07-15 来自:开发者社区

在Flink CDC中数据量太大 第一次全量同步咋整 ?

在Flink CDC中数据量太大 第一次全量同步咋整 ?

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

在Flink CDC中Doris中的数据比MySql中的数据量要多是啥情况?

在Flink CDC中CDC整库同步MySql数据到Doris中,Doris中的数据比MySql中的数据量要多是啥情况?

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之同步oracle表时,数据量约800万,检查点异常,该如何排查

问题一:Flink CDC 里像以Rowid创建的物化视图如果用cdc同步呢? Flink CDC 里像以Rowid创建的物化视图如果用cdc同步呢? 参考答案: 配置 Debezium:Debez...

实时计算 Flink版产品使用问题之同步oracle表时,数据量约800万,检查点异常,该如何排查
问答 2024-06-01 来自:开发者社区

Flink结果表数据量正确性问题

Flink结果表数据量正确性问题

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

Flink cdc source Records Sent比物理表数据量大

Flink cdc source Records Sent比物理表数据量大

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

实时计算 Flink版产品使用合集之nk任务在k8s上运行,数据量大时经常失败,并且某个TaskManager被cgroup杀掉,该如何处理

问题一:Flink CDC读貌似是有符号的-128---127? Flink CDC读貌似是有符号的-128---127?sqlserver的tinyint是0-255 ...

实时计算 Flink版产品使用合集之nk任务在k8s上运行,数据量大时经常失败,并且某个TaskManager被cgroup杀掉,该如何处理
问答 2024-04-15 来自:开发者社区

Flink CDC里每次同步pg固定的数据量就报这个错,有大佬知道为什么吗?

Flink CDC里每次同步pg固定的数据量就报这个错,有大佬知道为什么吗?

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

产品推荐

阿里云实时计算Flink

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

+关注