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

Flink CDC有遇到oracle cdc全量同步完后,提交offset的时候报这个错误?

Flink CDC有遇到oracle cdc全量同步完后,提交offset的时候报这个错误,本地调试的时候没这个错误,可以正常同步,到flink集群中运行的时候才报这个错误?

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

Flink CDC数据已经同步,但flink 作业还有异常?

Flink CDC从 mysql 8 到 flink 1.16.2 的 flink-sql 里,数据已经同步,但flink 作业还有异常。java.lang.RuntimeException: One or more fetchers have encountered exception at org.apache.flink.connector.base.source.reader.fe...

高性能

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

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

Flink CDC可以把初始同步完了用增量模式,但初始数据还是要同步,是这个意思吗?

Flink CDC可以把初始同步完了用增量模式,但初始数据还是要同步,除非初始的数据同步换成用其他工具先同步过去吧,是这个意思吗?

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

Flink CDC同步开源的那个postgresql数据库有碰到这个情况的不?

Flink CDC阿里云基于postgresql做的polardb我用flink 2.2 postgresql 连接器做同步。查询polardb的slot显示没有消费,但是我kafka显示收到了数据。这导致wal日志持续增加且不删除。同步开源的那个postgresql数据库有碰到这个情况的不?

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

Flink CDC这个问题遇到过吗?全量同步阶段报这个错误?

Flink CDC这个问题遇到过吗?全量同步阶段报这个错误?

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

flink cdc针对这两个阶段,如何证明或者验证数据库中所有数据都被正确同步了呢?

使用flink cdc同步mongodb数据到hudi,其中包含了snapshit和incremental两个阶段。针对这两个阶段,如何证明或者验证数据库中所有数据都被正确同步了呢?

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

mysql增加默认值,这个ddl操作,会导致flink cdc任务同步失败吗?

mysql增加默认值,这个ddl操作,会导致flink cdc任务同步失败吗?

文章 2023-11-08 来自:开发者社区

Flink CDC在进行全量同步时

Flink CDC在进行全量同步时,通常会在后台进行数据抓取和处理,这个过程可能会持续一段时间,特别是在处理大数据集时。在这个过程中,Flink会自动进行checkpoint以确保数据处理的正确性。 如果你的checkpoint没有成功,可能有以下几个原因: 内存不足:Flink在进行数据抓取和处理...

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

Flink CDC中ticdc能不能全量同步的时候控制速率嘛?

Flink CDC中ticdc能不能全量同步的时候控制速率嘛?

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

Flink CDC有没有遇到过同步MySQL一直卡在某个binlog文件?

Flink CDC有没有遇到过同步MySQL一直卡在某个binlog文件?数据库已经确认后续的binlog都生成了 io日志:io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Stopped reading binlog after 0 events, no new offset was recorded io.de....

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

产品推荐

阿里云实时计算Flink

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

+关注