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

Flink数据同步过程中发生错误,怎么保证作业重启后从这个时间点之前传递?

Flink数据同步过程中发生错误,怎么保证作业重启后从这个时间点之前传递?保证数据的完整性

文章 2024-03-18 来自:开发者社区

有大佬知道在使用flink cdc实现数据同步,如何实现如果服务停止了对数据源表的某个数据进行删除操作,重启服务之后目标表能进行对源表删除的数据进行删除吗?

有大佬知道在使用flink cdc实现数据同步,如何实现如果服务停止了对数据源表的某个数据进行删除操作,重启服务之后目标表能进行对源表删除的数据进行删除吗? Flink CDC(Change Data Capture)可以捕获源数据库的变更事件,包括插入、更新和删除操作。当Flink CDC连接到源数据库时&#x...

文章 2024-02-24 来自:开发者社区

Flink CDC数据同步问题之用savepoint重启任务报错如何解决

问题一:请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄 请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/503721?spm=a2c6h.13066369.questio...

Flink CDC数据同步问题之用savepoint重启任务报错如何解决

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

产品推荐

阿里云实时计算Flink

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

+关注